i'm using old version -0.8.2 cuase i imported project using this version so i want to work with it first , but if i want to upgrade this version what is the prequesities that i shoud do it in the project to keep up with the new version i mean is there any files i should replace it with new version of storm like in m2/repository ? it's first time to deal with this type > i'll apperciate your help Thanks
On Fri, Dec 18, 2015 at 10:11 AM, Don Frascuchon <[email protected]> wrote: > 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: >> >>
