开发者社区> 问答> 正文

storm redis 本地运行报错?报错

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]

展开
收起
爱吃鱼的程序员 2020-06-08 15:42:20 634 0
1 条回答
写回答
取消 提交回答
  • https://developer.aliyun.com/profile/5yerqm5bn5yqg?spm=a2c6h.12873639.0.0.6eae304abcjaIB

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

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

    2020-06-08 15:42:36
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Redis在唯品会的应用实践——架构演进与功能定制 立即下载
微博的Redis定制之路 立即下载
云数据库Redis版的开源之路 立即下载