23653 [Thread-61-countBolt] ERROR backtype.storm.util - Async loop died!
java.lang.RuntimeException: redis.clients.jedis.exceptions.JedisDataException: MOVED 14896 192.168.64.134:6379
at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:128) ~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:99) ~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80) ~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.daemon.executor$fn__4317$fn__4329$fn__4376.invoke(executor.clj:748) ~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.util$async_loop$fn__458.invoke(util.clj:463) ~[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_60]
Caused by: redis.clients.jedis.exceptions.JedisDataException: MOVED 14896 192.168.64.134:6379
at redis.clients.jedis.Protocol.processError(Protocol.java:66) ~[jedis-2.2.1.jar:na]
at redis.clients.jedis.Protocol.process(Protocol.java:73) ~[jedis-2.2.1.jar:na]
at redis.clients.jedis.Protocol.read(Protocol.java:138) ~[jedis-2.2.1.jar:na]
at redis.clients.jedis.Connection.getIntegerReply(Connection.java:191) ~[jedis-2.2.1.jar:na]
at redis.clients.jedis.Jedis.hset(Jedis.java:627) ~[jedis-2.2.1.jar:na]
at com.beicai.storm.CountBolt.execute(CountBolt.java:35) ~[classes/:na]
at backtype.storm.daemon.executor$fn__4317$tuple_action_fn__4319.invoke(executor.clj:633) ~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.daemon.executor$mk_task_receiver$fn__4240.invoke(executor.clj:401) ~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.disruptor$clojure_handler$reify__1607.onEvent(disruptor.clj:58) ~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:125) ~[storm-core-0.9.5.jar:0.9.5]
... 6 common frames omitted
23653 [Thread-59-countBolt] ERROR backtype.storm.util - Async loop died!
java.lang.RuntimeException: redis.clients.jedis.exceptions.JedisDataException: MOVED 14896 192.168.64.134:6379
at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:128) ~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:99) ~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80) ~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.daemon.executor$fn__4317$fn__4329$fn__4376.invoke(executor.clj:748) ~[storm-core-0.9.5.jar:0.9.5]
at backtype.storm.util$async_loop$fn__458.invoke(util.clj:463) ~[storm-core-0.9.5.jar:0.9.5]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
你的redis应该是搭建的集群吧
如果连接Redis集群,要用JedisCluster代替ShardedJedis才可以,而且JedisCluster还没有pipeline模式,所以一次只能执行一个操作
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。