hadoop - Zookeeper和Storm的错误

Question

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

我的异常(exception)是:

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());

希望对您有帮助。