zookeeper和storm出错

Question

我正在为Storm开发一个代码，这是开发人员的一个例子。我的问题是，当您从IDE Eclipse运行此代码时，没有在Storm和Zookeeper之间建立连接。Zookeeper在2181中运行，也在storm.yaml中设置。

我的例外是：

72992 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN  o.a.s.s.o.a.z.s.NIOServerCnxn - caught end of stream exception
org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x15432be39f50004, likely client has closed socket
    at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) [storm-core-1.0.0.jar:1.0.0]
    at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.0.0.jar:1.0.0]
    at java.lang.Thread.run(Thread.java:745) [?:1.7.0_67]
73194 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO  o.a.s.s.o.a.z.s.NIOServerCnxn - Closed socket connection for client /127.0.0.1:37597 which had sessionid 0x15432be39f50004

有什么想法或程序需要执行吗？从配置代码中传递？和我一样呢？

Answer 1

我在过去向Storm讨饭时也遇到过同样的问题。我还不是专家，但我可以说@Matthias J.Sax是对的，拓扑必须在本地模式下运行才能在Eclipse上启动。我用Eclipse Mars做到了这一点，运行Storm 0.10.0，工作得很完美。你必须这样做：

替换：

StormSubmitter.submitTopology("test", conf, builder.createTopology());

通过以下方式：

 LocalCluster cluster = new LocalCluster();
      cluster.submitTopology("test", conf, builder.createTopology());

希望对你有帮助。