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

Posted 2020-11-19 yjcblog

在本地编辑工具写了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);