首页 > 其他 > 详细

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

时间:2018-06-22 12:34:54      阅读:198      评论:0      收藏:0      [点我收藏+]

在本地编辑工具写了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本地模式运行无执行问题

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

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!