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