You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Bilal Al Fartakh <al...@gmail.com> on 2014/03/25 12:19:43 UTC
Async loop interrupted
Storm Users ,
I Tried an example from Storm-Starter , ExclamationTopology .
and while I compile/Run in a local mode , the process continue to work
normally until I'm faced with this * : backtype.storm.util - Async loop
interrupted!
is normal to see this message ?
*
17406 [Thread-27-exclaim2] INFO backtype.storm.daemon.executor -
Processing received message source: exclaim1:4, stream: default, id: {},
[golda!!!]
17406 [Thread-27-exclaim2] INFO backtype.storm.daemon.task - Emitting:
exclaim2 default [golda!!!!!!]
17409 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.supervisor - Shutting down
a9803b09-183e-4a36-b6de-94f63ab2f5e1:83b1b4c1-db7a-49cd-94dd-9aed9add81e0
17410 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.process-simulator - Killing process
975fc479-47d0-4ac8-b961-3fadf1a5c683
17411 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.worker - Shutting down worker test-1-1395686774
a9803b09-183e-4a36-b6de-94f63ab2f5e1 4
17411 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.worker - Shutting down receive thread
17412 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.messaging.loader - Shutting down receiving-thread:
[test-1-1395686774, 4]
17412 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.messaging.loader - Waiting for
receiving-thread:[test-1-1395686774, 4] to die
17413 [Thread-52] INFO backtype.storm.messaging.loader -
Receiving-thread:[test-1-1395686774, 4] received shutdown notice
17413 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.messaging.loader - Shutdown receiving-thread:
[test-1-1395686774, 4]
17413 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.worker - Shut down receive thread
17414 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.worker - Terminating messaging context
17414 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.worker - Shutting down executors
17414 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shutting down executor exclaim1:[2 2]
17416 [Thread-19-exclaim1] INFO backtype.storm.util - Async loop
interrupted!
17417 [Thread-18] INFO backtype.storm.util - Async loop interrupted!
17419 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shut down executor exclaim1:[2 2]
17419 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shutting down executor exclaim1:[3 3]
17420 [Thread-21-exclaim1] INFO backtype.storm.util - Async loop
interrupted!
17421 [Thread-43-word] INFO backtype.storm.daemon.task - Emitting: word
default [jackson]
17422 [Thread-20] INFO backtype.storm.util - Async loop interrupted!
17423 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shut down executor exclaim1:[3 3]
17423 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shutting down executor exclaim1:[4 4]
17424 [Thread-23-exclaim1] INFO backtype.storm.util - Async loop
interrupted!
17425 [Thread-22] INFO backtype.storm.util - Async loop interrupted!
17426 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shut down executor exclaim1:[4 4]
17426 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shutting down executor exclaim2:[5 5]
17427 [Thread-25-exclaim2] INFO backtype.storm.util - Async loop
interrupted!
17427 [Thread-24] INFO backtype.storm.util - Async loop interrupted!
17428 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shut down executor exclaim2:[5 5]
17428 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shutting down executor exclaim2:[6 6]
17429 [Thread-27-exclaim2] INFO backtype.storm.util - Async loop
interrupted!
17430 [Thread-26] INFO backtype.storm.util - Async loop interrupted!
17430 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shut down executor exclaim2:[6 6]
17431 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shutting down executor word:[7 7]
17431 [Thread-28] INFO backtype.storm.util - Async loop interrupted!
17432 [Thread-29-word] INFO backtype.storm.util - Async loop interrupted!
17433 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shut down executor word:[7 7]
17433 [storm.starter.ExclamationTopology.main()] INFO
backtype.storm.daemon.executor - Shutting down executor word:[8 8]
--
*Al Fartakh Bilal*
Re: Async loop interrupted
Posted by Bilal Al Fartakh <al...@gmail.com>.
Enno ,
thank you very much for your help a second time !
cheers !
Re: Async loop interrupted
Posted by Enno Shioji <es...@gmail.com>.
It's doing an orderly shutdown because the sample code kills the topology
after 10 seconds
On Tue, Mar 25, 2014 at 11:19 AM, Bilal Al Fartakh <alfartaj.bilal@gmail.com
> wrote:
> Storm Users ,
> I Tried an example from Storm-Starter , ExclamationTopology .
> and while I compile/Run in a local mode , the process continue to work
> normally until I'm faced with this * : backtype.storm.util - Async loop
> interrupted!
> is normal to see this message ?
>
>
>
>
> *
> 17406 [Thread-27-exclaim2] INFO backtype.storm.daemon.executor -
> Processing received message source: exclaim1:4, stream: default, id: {},
> [golda!!!]
> 17406 [Thread-27-exclaim2] INFO backtype.storm.daemon.task - Emitting:
> exclaim2 default [golda!!!!!!]
> 17409 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.supervisor - Shutting down
> a9803b09-183e-4a36-b6de-94f63ab2f5e1:83b1b4c1-db7a-49cd-94dd-9aed9add81e0
> 17410 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.process-simulator - Killing process
> 975fc479-47d0-4ac8-b961-3fadf1a5c683
> 17411 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.worker - Shutting down worker test-1-1395686774
> a9803b09-183e-4a36-b6de-94f63ab2f5e1 4
> 17411 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.worker - Shutting down receive thread
> 17412 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.messaging.loader - Shutting down receiving-thread:
> [test-1-1395686774, 4]
> 17412 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.messaging.loader - Waiting for
> receiving-thread:[test-1-1395686774, 4] to die
> 17413 [Thread-52] INFO backtype.storm.messaging.loader -
> Receiving-thread:[test-1-1395686774, 4] received shutdown notice
> 17413 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.messaging.loader - Shutdown receiving-thread:
> [test-1-1395686774, 4]
> 17413 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.worker - Shut down receive thread
> 17414 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.worker - Terminating messaging context
> 17414 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.worker - Shutting down executors
> 17414 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shutting down executor exclaim1:[2 2]
> 17416 [Thread-19-exclaim1] INFO backtype.storm.util - Async loop
> interrupted!
> 17417 [Thread-18] INFO backtype.storm.util - Async loop interrupted!
> 17419 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shut down executor exclaim1:[2 2]
> 17419 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shutting down executor exclaim1:[3 3]
> 17420 [Thread-21-exclaim1] INFO backtype.storm.util - Async loop
> interrupted!
> 17421 [Thread-43-word] INFO backtype.storm.daemon.task - Emitting: word
> default [jackson]
> 17422 [Thread-20] INFO backtype.storm.util - Async loop interrupted!
> 17423 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shut down executor exclaim1:[3 3]
> 17423 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shutting down executor exclaim1:[4 4]
> 17424 [Thread-23-exclaim1] INFO backtype.storm.util - Async loop
> interrupted!
> 17425 [Thread-22] INFO backtype.storm.util - Async loop interrupted!
> 17426 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shut down executor exclaim1:[4 4]
> 17426 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shutting down executor exclaim2:[5 5]
> 17427 [Thread-25-exclaim2] INFO backtype.storm.util - Async loop
> interrupted!
> 17427 [Thread-24] INFO backtype.storm.util - Async loop interrupted!
> 17428 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shut down executor exclaim2:[5 5]
> 17428 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shutting down executor exclaim2:[6 6]
> 17429 [Thread-27-exclaim2] INFO backtype.storm.util - Async loop
> interrupted!
> 17430 [Thread-26] INFO backtype.storm.util - Async loop interrupted!
> 17430 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shut down executor exclaim2:[6 6]
> 17431 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shutting down executor word:[7 7]
> 17431 [Thread-28] INFO backtype.storm.util - Async loop interrupted!
> 17432 [Thread-29-word] INFO backtype.storm.util - Async loop interrupted!
> 17433 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shut down executor word:[7 7]
> 17433 [storm.starter.ExclamationTopology.main()] INFO
> backtype.storm.daemon.executor - Shutting down executor word:[8 8]
>
> --
> *Al Fartakh Bilal*
>