动物园管理员和错误风暴

本文介绍了动物园管理员和错误风暴的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！

问题描述

限时送ChatGPT账号..

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

I am developing a code for Storm, which is an example of the developers. My problem is that when you run this code from IDE Eclipse, do not get the connection between Storm and Zookeeper is established. Zookeeper is running in 2181 and is also set in 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.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x15432be39f50004, likely client has closed socket
    at org.apache.storm.shade.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) [storm-core-1.0.0.jar:1.0.0]
    at org.apache.storm.shade.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

有什么想法或要执行的程序吗?从配置代码传过来?和我一样?

Any idea or procedure to be performed? Pass from the configuration code? And as I do?

推荐答案

我过去遇到过同样的问题，当我开始使用 Storm 时.我还不是专家，但我可以说@Matthias J. Sax 是对的，拓扑必须以本地模式运行才能在 Eclipse 上启动它.我用 Eclipse Mars 做到了这一点，运行 Storm 0.10.0 并且运行完美.你必须这样做:

I faced the same issue in the past,when I was beggining with Storm. I'm not an expert yet, but I can afford to say that @Matthias J. Sax is right, the topology must run in local-mode to start it on Eclipse. I did that with Eclipse Mars, running Storm 0.10.0 and worked perfect. You have to do this:

替换:

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

与:

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

希望对你有帮助.

这篇关于动物园管理员和错误风暴的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！