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 <[email protected] > 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* >
