码迷,mamicode.com
首页 > 其他好文 > 详细

storm本地模式运行无执行问题

时间:2018-06-22 13:31:13      阅读:1975      评论:0      收藏:0      [点我收藏+]

标签:exce   pre   例子   错误   local   完成   zookeeper   addition   初始   

在本地编辑工具写了strom的例子,用 LocalCluster 运行后,并没有打印出预期的内容,反而在日志里有出现错误:

org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x164258d72a2000b, likely client has closed socket
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) [storm-core-1.2.2.jar:1.2.2]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.2.2.jar:1.2.2]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_171]

经排查,是主线程休眠的时间太短了,看了网上的设置,都是休眠10s,而此时storm还没有初始化完成,所以导致还没开始就结束了

解决方案:将休眠时间调高,让程序可以正常执行

Utils.sleep(10000);

  

 

storm本地模式运行无执行问题

标签:exce   pre   例子   错误   local   完成   zookeeper   addition   初始   

原文地址:https://www.cnblogs.com/yjcblog/p/9212643.html

(0)
(1)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!