Асинхронный цикл умер! org.zeromq.ZMQException

Question

У меня есть это в файле журнала работника, как я могу решить это?

[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 

носик в интерфейсе не emit

рабочий журнал после выполнения команды запуска

 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) "

Answer 1

Похоже, что порт не бесплатный. Убедитесь, что ни один другой процесс / служба не использует порт или перенастроил Storm для использования другого порта.

Для того, чтобы изменить порт, вам нужно отредактировать conf/storm.yaml файл (лучше всего на каждой машине, на которой работает супервизор). Сравнить с defaults.yaml чтобы найти правильное имя параметра.

Вторая ошибка связана с локальным каталогом Storm tmp. Попробуйте выключить кластер, очистить этот каталог и перезапустить Storm.