Zookeeper 和 Storm 出错答案

【问题标题】：Error with zookeeper & stormZookeeper 和 Storm 出错
【发布时间】：2016-06-21 19:29:10
【问题描述】：

我正在为 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

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

【问题讨论】：

如果您在 IDE 中运行，您应该使用 LocalCluster，它不需要运行外部 ZK。

标签： hadoop apache-storm apache-zookeeper

【解决方案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());

希望对你有所帮助。

【讨论】：