2016-02-19 104 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

相关问题