0
我一直在努力獲得風暴工作的本地副本,遵循storm-starter回購指南以及此tutorial。本地羣集模式下運行Apache Storm需要本地Zookeeper羣集嗎?
當試圖用mvn compile exec:java -Dstorm.topology=org.apache.storm.starter.ExclamationTopology
運行拓撲結構中,輸出最終繼續循環&垃圾郵件:
28534 [Thread-9-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error)
28534 [Thread-9-SendThread(localhost:2000)] WARN o.a.s.s.o.a.z.ClientCnxn - Session 0x152f7728a6a0011 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[?:1.8.0_45]
at Sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[?:1.8.0_45]
at org.apache.storm.shade.org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361) ~[storm-core-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
at org.apache.storm.shade.org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081) [storm-core-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT]
看來它正試圖連接到本地動物園管理員組,但我還沒有看到的依賴或安裝Storm文檔中的Zookeeper需求或其他教程中的需求。
我需要安裝Zookeeper嗎?這只是從文檔中丟失嗎?也許我錯了,它正在我的本地主機端口2000上尋找其他東西?如果沒有,我的本地設置出了什麼問題?
謝謝澄清。我發佈了另一個關於我在遇到'storm-starter'回購指南時遇到的錯誤的問題:http://stackoverflow.com/questions/35507922/unable-to-run-a-storm-starter-topology-from-在風暴教程 – user2666425