[STORM-723] [storm-redis] RedisStateSetUpdater writes state into String but calls Set operation

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.0
• Fix Version/s: 0.10.0
• Component/s: storm-redis
• Assignee: Jungtaek Lim
• Reporter: Jungtaek Lim
• Created: 25/Mar/15 00:58
• Updated: 26/Sep/15 02:22
• Resolved: 26/Mar/15 14:40

Description

RedisStateSetUpdater writes value into String type, but it tries to retrieve Set's element count from String type which will throw JedisDataException.

                if (this.expireIntervalSec > 0) {
                    jedis.setex(redisKey, expireIntervalSec, value);
                } else {
                    jedis.set(redisKey, value);
                }
                Long count = jedis.scard(redisKey);

Btw, Redis expire only applies to key, so above implementation seems to be invalid.

Issue Links

• is related to: STORM-722 [storm-redis] Apply various Redis data types to Trident