storm redis 本地运行报错

出发 发布于 2017/04/09 16:20
阅读 150
收藏 0

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]

加载中
0
草丛有蟲
草丛有蟲

你的redis应该是搭建的集群吧 

如果连接Redis集群,要用JedisCluster 代替ShardedJedis 才可以,而且JedisCluster 还没有pipeline 模式,所以一次只能执行一个操作

返回顶部
顶部