Repository: storm Updated Branches: refs/heads/master 90e4f3e8a -> 3a7cfc8e7
add missing break Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1c87f4aa Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1c87f4aa Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1c87f4aa Branch: refs/heads/master Commit: 1c87f4aaa5352ec4f68f7dd8dbe0d762c5b2c9d6 Parents: 90e4f3e Author: Xin Wang <[email protected]> Authored: Sat Jan 16 21:03:47 2016 +0800 Committer: Xin Wang <[email protected]> Committed: Sat Jan 16 21:03:47 2016 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/storm/redis/bolt/RedisStoreBolt.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/1c87f4aa/external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisStoreBolt.java ---------------------------------------------------------------------- diff --git a/external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisStoreBolt.java b/external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisStoreBolt.java index b74ed1c..c774dc0 100644 --- a/external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisStoreBolt.java +++ b/external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisStoreBolt.java @@ -94,6 +94,7 @@ public class RedisStoreBolt extends AbstractRedisBolt { case SORTED_SET: jedisCommand.zadd(additionalKey, Double.valueOf(value), key); + break; case HYPER_LOG_LOG: jedisCommand.pfadd(key, value);
