【问题标题】:Async loop died! org.zeromq.ZMQException异步循环死了! org.zeromq.ZMQException
【发布时间】: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


【解决方案1】:

看来移植不是免费的。确保没有其他进程/服务使用该端口或重新配置 Storm 以使用不同的端口。

为了更改端口,您需要编辑conf/storm.yaml 文件(最好在每台运行管理员的机器上)。请与defaults.yaml 进行比较以找到正确的参数名称。

第二个错误似乎与本地 Storm tmp 目录有关。尝试关闭集群,清除此目录,然后重新启动 Storm。

【讨论】:

  • 但是为什么supervisor还没开始呢?
  • 根据错误信息,主管试图打开一个已经被占用的端口。因此它无法启动...
  • 但是工人如何完成他的工作?对不起,我没弄好
  • 执行在主管和工作人员之间启动的命令后,我在工作人员日志文件中找到了我现在将在帖子中编辑的内容
  • 似乎 Storm 试图恢复一个旧的拓扑。您是否确保在停止 Storm 之前拓扑已被正确终止和清理?也许停止 Zookeeper 并清理 Zookeeper tmp 目录可以帮助清理旧状态...
猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2015-08-14
  • 1970-01-01
  • 1970-01-01
  • 2018-10-17
  • 2018-09-18
  • 2021-06-01
相关资源
最近更新 更多