2016-02-19 134 views
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上尋找其他東西?如果沒有,我的本地設置出了什麼問題?

回答

1

如果你在本地運行並使用LocalCluter你做不是需要安裝Zookeeper。

如果您以僞分佈模式(即,在本地啓動Nimubs和Supervisor)本地運行並使用StormSubmitter,則您需要在本地安裝Zookeeper。

+0

謝謝澄清。我發佈了另一個關於我在遇到'storm-starter'回購指南時遇到的錯誤的問題:http://stackoverflow.com/questions/35507922/unable-to-run-a-storm-starter-topology-from-在風暴教程 – user2666425

相關問題