飼い葉桶と嵐のエラー

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

私は過去に同じ問題に直面しました。私がストームと立ち上がっていたときです。私はまだエキスパートではありませんが、@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()); 

それはあなたを助け願っています。