【发布时间】:2015-10-12 08:07:55
【问题描述】:
我在工作日志文件中有这个问题,我该如何解决?
[ERROR] Async loop died! org.zeromq.ZMQException:
Address already in use(0x62)
at org.zeromq.ZMQ$Socket.bind(Native Method)
at zilch.mq$bind.invoke(mq.clj:69)
at backtype.storm.messaging.zmq.ZMQContext.bind(zmq.clj:57)at backtype.storm.messaging.loader$launch_receive_thread_BANG_$fn__1629.invoke(loader.clj:26)
at backtype.storm.util$async_loop$fn__465.invoke(util.clj:375)
at clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Unknown Source)
和主管
still hasn't start
ui 中的 spout 没有 emit
执行启动命令后的worker日志文件
ERROR] Error on initialization of server mk-worker
java.io.IOException: No such file or directory
at java.io.UnixFileSystem.createFileExclusively(Native Method)
at java.io.File.createNewFile(Unknown Source)
at backtype.storm.util$touch.invoke(util.clj:432)
at backtype.storm.daemon.worker$fn__4348$exec_fn__1228__auto____4349.invoke(worker.clj:331)
at clojure.lang.AFn.applyToHelper(AFn.java:185)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:601)
at backtype.storm.daemon.worker$fn__4348$mk_worker__4404.doInvoke(worker.clj:323)
at clojure.lang.RestFn.invoke(RestFn.java:512)
at backtype.storm.daemon.worker$_main.invoke(worker.clj:433)
at clojure.lang.AFn.applyToHelper(AFn.java:172)
at clojure.lang.AFn.applyTo(AFn.java:151)
at backtype.storm.daemon.worker.main(Unknown Source)
INFO] Halting process: ("Error on initialization")
这是重启风暴后发生的事情
1- i tried to kill the topology
2- remove what storm-local folder contain
3- restart connect nimbus and supervisor
我现在的结果
1- some executors in nimbus not alive and trying to clean up the topology
2- 主管有此消息
[ERROR] Error when processing event java.io.FileNotFoundException:
File does not exist: storm-local/workers/361c029c-b9c5-4ca7-
bced-f8ea084d45a3/heartbeats "/1444899266048
3- 工作日志文件
"worker 361c029c-b9c5-4ca7-bced-f8ea084d45a3 for storm topology name on
9d05b304-6bb5-497e-85b3-656eb82fb37e:6704 has finished loading
2015-10-15 10:50:46 executor [INFO] Deactivating spout spout0:(57) "
【问题讨论】:
-
看来 to port 不是免费的。确保没有其他进程/服务使用该端口或重新配置 Storm 以使用不同的端口。
-
感谢您的回复,我认为您是对的,我为主管使用了另一个端口并尝试在名为 vp4_ip_local_port 的文件中进行编辑,但主管仍然有这个消息“仍然没有启动”但是工人有这个“工人 28b76eb7-e6de-4a2a-81ee-91c5716dd493 风暴拓扑名称 0950c07f-4b43-4e17-9b23-2b9c1b4b6c06:6703 已完成加载”!“工人如何完成并提交拓扑而主管仍未启动?跨度>
-
你能帮忙解决这个stackoverflow.com/questions/33142241/…吗?
标签: apache-storm topology apache-zookeeper