Hi, Which version of storm are using ? Newer versions use netty for worker comunications instead zero MQ.
El jue., 17 dic. 2015 a las 7:08, sam mohel (<[email protected]>) escribió: > i've problem with submitting topology i got in the supervisor log file still > hasn't start and in the worker log file > > 2015-12-17 07:52:23 task [INFO] Emitting: b-7 __system ["startup"] > 2015-12-17 07:52:23 executor [INFO] Loaded executor tasks b-7:[33 33] > 2015-12-17 07:52:23 executor [INFO] Preparing bolt b-7:(33) > 2015-12-17 07:52:23 executor [INFO] Finished loading executor b-7:[33 33] > 2015-12-17 07:52:23 worker [INFO] Launching receive-thread for > 5587bcc1-05d4-4d92-ae3d-2a8503cef259:6706 > 2015-12-17 07:52:23 executor [INFO] Prepared bolt b-7:(33) > > after finished loading got alot of this lines > > 2015-12-17 07:52:27 executor [INFO] Processing received message source: > __system:-1, stream: __tick, id: {}, [5] > 2015-12-17 07:52:27 executor [INFO] Processing received message source: > __system:-1, stream: __tick, id: {}, [5] > > Got in the storm ui zeros in emitted and transfered > > i executed the command that launch worker and supervisor got > > 2015-12-17 07:59:04 executor [INFO] Prepared bolt b-7:(33) > 2015-12-17 07:59:04 util [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(Thread.java:701) > 2015-12-17 07:59:04 util [INFO] Halting process: > >
