Chyba pri zookeeper & storm - hadoop, apache-storm, apache-zookeeper

Vyvíjam kód pre Storm, ktorý jepríklad vývojárov. Môj problém je, že keď spustíte tento kód z IDE Eclipse, nezíska sa spojenie medzi Storm a Zookeeper je nadviazané. Zookeeper beží v roku 2181 a je tiež umiestnený v storm.yaml.

Moja výnimka je:

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

Máte nejaký nápad alebo postup, ktorý sa má vykonať? Prejdite z konfiguračného kódu? A ako ja?

odpovede:

Rovnakému problému som čelil v minulosti, keď som bolzačínajúc s Storm. Zatiaľ nie som odborník, ale môžem si dovoliť povedať, že @ Matthias J. Sax má pravdu, topológia sa musí spustiť v lokálnom režime, aby sa spustila na Eclipse. Urobila som to pomocou Eclipse Mars, spustením Storm 0,10 a fungovalo perfektne. Musíte to urobiť:

nahradiť:

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

s:

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

Dúfam, že vám to pomohlo.