I replaced the wordcount example with the exclamation example, using: *mvn compile exec:java -Dstorm.topology=storm.starter.ExclamationTopology*
... and that ran perfectly. I did see pages of INFO statements before the error. I think it's an issue with WordCountTopology, as I see a JIRA already created <https://issues.apache.org/jira/browse/STORM-531> about the first error below. ------------------------------------------------- 23866 [Thread-26] ERROR backtype.storm.task.ShellBolt - Halting process: ShellBolt died. java.lang.RuntimeException: backtype.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. Serializer Exception: at backtype.storm.utils.ShellProcess.readShellMsg(ShellProcess.java:101) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at backtype.storm.task.ShellBolt$BoltReaderRunnable.run(ShellBolt.java:318) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_65] 23865 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shutting down executor count:[3 3] 23867 [Thread-36] INFO backtype.storm.daemon.executor - TRANSFERING tuple TASK: 3 TUPLE: source: split:5, stream: default, id: {}, ["the"] 23867 [Thread-35-count] INFO backtype.storm.daemon.executor - Processing received message FOR 4 TUPLE: source: split:5, stream: default, id: {}, ["an d"] 23870 [Thread-17-count] INFO backtype.storm.util - Async loop interrupted! 23872 [Thread-36] INFO backtype.storm.daemon.executor - TRANSFERING tuple TASK: 2 TUPLE: source: split:5, stream: default, id: {}, ["seven"] 23870 [Thread-16-disruptor-executor[3 3]-send-queue] INFO backtype.storm.util - Async loop interrupted! 23870 [Thread-26] ERROR backtype.storm.daemon.executor - java.lang.RuntimeException: backtype.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. Serializer Exception: at backtype.storm.utils.ShellProcess.readShellMsg(ShellProcess.java:101) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at backtype.storm.task.ShellBolt$BoltReaderRunnable.run(ShellBolt.java:318) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_65] 23874 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shut down executor count:[3 3] 23877 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shutting down executor __acker:[1 1] 23879 [Thread-19-__acker] INFO backtype.storm.util - Async loop interrupted! 23874 [Thread-36] INFO backtype.storm.daemon.executor - TRANSFERING tuple TASK: 4 TUPLE: source: split:5, stream: default, id: {}, ["dwarfs"] [WARNING] 23872 [Thread-35-count] INFO backtype.storm.daemon.executor - BOLT ack TASK: 4 TIME: TUPLE: source: split:5, stream: default, id: {}, ["and"] java.lang.RuntimeException: java.lang.InterruptedException at backtype.storm.util$wrap_in_runtime.invoke(util.clj:48) at backtype.storm.zookeeper$exists_node_QMARK_$fn__1958.invoke(zookeeper.clj:103) at backtype.storm.zookeeper$exists_node_QMARK_.invoke(zookeeper.clj:99) at backtype.storm.zookeeper$mkdirs.invoke(zookeeper.clj:115) at backtype.storm.cluster$mk_distributed_cluster_state$reify__2232.mkdirs(cluster.clj:128) at backtype.storm.cluster$mk_storm_cluster_state$reify__2772.report_error(cluster.clj:446) at backtype.storm.daemon.executor$throttled_report_error_fn$fn__4452.invoke(executor.clj:183) at backtype.storm.daemon.executor$fn__4673$fn$reify__4721.reportError(executor.clj:788) at backtype.storm.task.OutputCollector.reportError(OutputCollector.java:223) at backtype.storm.task.ShellBolt.die(ShellBolt.java:283) at backtype.storm.task.ShellBolt.access$400(ShellBolt.java:69) at backtype.storm.task.ShellBolt$BoltReaderRunnable.run(ShellBolt.java:341) at java.lang.Thread.run(Thread.java:745) Caused by: java.lang.InterruptedException at java.lang.Object.wait(Native Method) at java.lang.Object.wait(Object.java:503) at org.apache.storm.zookeeper.ClientCnxn.submitRequest(ClientCnxn.java:1342) at org.apache.storm.zookeeper.ZooKeeper.exists(ZooKeeper.java:1040) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:172) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:161) at org.apache.storm.curator.RetryLoop.callWithRetry(RetryLoop.java:107) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl.pathInForeground(ExistsBuilderImpl.java:157) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:148) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:36) at backtype.storm.zookeeper$exists_node_QMARK_$fn__1958.invoke(zookeeper.clj:102) ... 11 more 23879 [Thread-18-disruptor-executor[1 1]-send-queue] INFO backtype.storm.util - Async loop interrupted! 23881 [Thread-36] INFO backtype.storm.daemon.executor - BOLT ack TASK: 5 TIME: TUPLE: source: spout:10, stream: default, id: {}, [snow white and the seven dwarfs] 23881 [Thread-35-count] INFO backtype.storm.daemon.executor - Execute done TUPLE source: split:5, stream: default, id: {}, ["and"] TASK: 4 DELTA: 23899 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shut down executor __acker:[1 1] 23900 [Thread-35-count] INFO backtype.storm.daemon.executor - Processing received message FOR 4 TUPLE: source: split:5, stream: default, id: {}, ["dw arfs"] 23900 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shutting down executor split:[6 6] 23902 [Thread-20-disruptor-executor[6 6]-send-queue] INFO backtype.storm.util - Async loop interrupted! 23903 [Thread-21-split] INFO backtype.storm.util - Async loop interrupted! 23902 [Thread-35-count] INFO backtype.storm.daemon.executor - BOLT ack TASK: 4 TIME: TUPLE: source: split:5, stream: default, id: {}, ["dwarfs"] 23904 [Thread-35-count] INFO backtype.storm.daemon.executor - Execute done TUPLE source: split:5, stream: default, id: {}, ["dwarfs"] TASK: 4 DELTA: 23905 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shut down executor split:[6 6] 23907 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shutting down executor spout:[9 9] 23909 [Thread-22-disruptor-executor[9 9]-send-queue] INFO backtype.storm.util - Async loop interrupted! 23909 [Thread-23-spout] INFO backtype.storm.util - Async loop interrupted! 23910 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shut down executor spout:[9 9] 23912 [Thread-28] ERROR backtype.storm.task.ShellBolt - Halting process: ShellBolt died. java.lang.RuntimeException: backtype.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. Serializer Exception: at backtype.storm.utils.ShellProcess.readShellMsg(ShellProcess.java:101) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at backtype.storm.task.ShellBolt$BoltReaderRunnable.run(ShellBolt.java:318) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_65] 23913 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shutting down executor __system:[-1 -1] 23915 [Thread-28] ERROR backtype.storm.daemon.executor - java.lang.RuntimeException: backtype.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. Serializer Exception: at backtype.storm.utils.ShellProcess.readShellMsg(ShellProcess.java:101) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at backtype.storm.task.ShellBolt$BoltReaderRunnable.run(ShellBolt.java:318) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_65] [WARNING] java.lang.RuntimeException: java.lang.InterruptedException at backtype.storm.util$wrap_in_runtime.invoke(util.clj:48) at backtype.storm.zookeeper$exists_node_QMARK_$fn__1958.invoke(zookeeper.clj:103) at backtype.storm.zookeeper$exists_node_QMARK_.invoke(zookeeper.clj:99) at backtype.storm.zookeeper$mkdirs.invoke(zookeeper.clj:115) at backtype.storm.cluster$mk_distributed_cluster_state$reify__2232.mkdirs(cluster.clj:128) at backtype.storm.cluster$mk_storm_cluster_state$reify__2772.report_error(cluster.clj:446) at backtype.storm.daemon.executor$throttled_report_error_fn$fn__4452.invoke(executor.clj:183) at backtype.storm.daemon.executor$fn__4673$fn$reify__4721.reportError(executor.clj:788) at backtype.storm.task.OutputCollector.reportError(OutputCollector.java:223) at backtype.storm.task.ShellBolt.die(ShellBolt.java:283) at backtype.storm.task.ShellBolt.access$400(ShellBolt.java:69) at backtype.storm.task.ShellBolt$BoltReaderRunnable.run(ShellBolt.java:341) at java.lang.Thread.run(Thread.java:745) Caused by: java.lang.InterruptedException at java.lang.Object.wait(Native Method) at java.lang.Object.wait(Object.java:503) at org.apache.storm.zookeeper.ClientCnxn.submitRequest(ClientCnxn.java:1342) at org.apache.storm.zookeeper.ZooKeeper.exists(ZooKeeper.java:1040) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:172) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:161) at org.apache.storm.curator.RetryLoop.callWithRetry(RetryLoop.java:107) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl.pathInForeground(ExistsBuilderImpl.java:157) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:148) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:36) at backtype.storm.zookeeper$exists_node_QMARK_$fn__1958.invoke(zookeeper.clj:102) ... 11 more 23916 [Thread-25-__system] INFO backtype.storm.util - Async loop interrupted! 23916 [Thread-24-disruptor-executor[-1 -1]-send-queue] INFO backtype.storm.util - Async loop interrupted! 23940 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shut down executor __system:[-1 -1] 23941 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shutting down executor split:[5 5] 23941 [Thread-31-split] INFO backtype.storm.util - Async loop interrupted! 23941 [Thread-30-disruptor-executor[5 5]-send-queue] INFO backtype.storm.util - Async loop interrupted! 23944 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shut down executor split:[5 5] 23945 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shutting down executor spout:[10 10] 23946 [Thread-33-spout] INFO backtype.storm.util - Async loop interrupted! 23947 [Thread-32-disruptor-executor[10 10]-send-queue] INFO backtype.storm.util - Async loop interrupted! 23949 [Thread-36] ERROR backtype.storm.task.ShellBolt - Halting process: ShellBolt died. java.lang.RuntimeException: backtype.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. Serializer Exception: at backtype.storm.utils.ShellProcess.readShellMsg(ShellProcess.java:101) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at backtype.storm.task.ShellBolt$BoltReaderRunnable.run(ShellBolt.java:318) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_65] 23949 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shut down executor spout:[10 10] 23952 [Thread-36] ERROR backtype.storm.daemon.executor - java.lang.RuntimeException: backtype.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. Serializer Exception: at backtype.storm.utils.ShellProcess.readShellMsg(ShellProcess.java:101) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at backtype.storm.task.ShellBolt$BoltReaderRunnable.run(ShellBolt.java:318) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_65] 23954 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shutting down executor count:[4 4] 23957 [Thread-35-count] INFO backtype.storm.util - Async loop interrupted! [WARNING] java.lang.RuntimeException: java.lang.InterruptedException at backtype.storm.util$wrap_in_runtime.invoke(util.clj:48) at backtype.storm.zookeeper$exists_node_QMARK_$fn__1958.invoke(zookeeper.clj:103) at backtype.storm.zookeeper$exists_node_QMARK_.invoke(zookeeper.clj:99) at backtype.storm.zookeeper$mkdirs.invoke(zookeeper.clj:115) at backtype.storm.cluster$mk_distributed_cluster_state$reify__2232.mkdirs(cluster.clj:128) at backtype.storm.cluster$mk_storm_cluster_state$reify__2772.report_error(cluster.clj:446) at backtype.storm.daemon.executor$throttled_report_error_fn$fn__4452.invoke(executor.clj:183) at backtype.storm.daemon.executor$fn__4673$fn$reify__4721.reportError(executor.clj:788) at backtype.storm.task.OutputCollector.reportError(OutputCollector.java:223) at backtype.storm.task.ShellBolt.die(ShellBolt.java:283) at backtype.storm.task.ShellBolt.access$400(ShellBolt.java:69) at backtype.storm.task.ShellBolt$BoltReaderRunnable.run(ShellBolt.java:341) at java.lang.Thread.run(Thread.java:745) Caused by: java.lang.InterruptedException at java.lang.Object.wait(Native Method) at java.lang.Object.wait(Object.java:503) at org.apache.storm.zookeeper.ClientCnxn.submitRequest(ClientCnxn.java:1342) at org.apache.storm.zookeeper.ZooKeeper.exists(ZooKeeper.java:1040) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:172) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:161) at org.apache.storm.curator.RetryLoop.callWithRetry(RetryLoop.java:107) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl.pathInForeground(ExistsBuilderImpl.java:157) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:148) at org.apache.storm.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:36) at backtype.storm.zookeeper$exists_node_QMARK_$fn__1958.invoke(zookeeper.clj:102) ... 11 more 23957 [Thread-34-disruptor-executor[4 4]-send-queue] INFO backtype.storm.util - Async loop interrupted! 23973 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.executor - Shut down executor count:[4 4] 23974 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.worker - Shut down executors 23974 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.worker - Shutting down transfer thread 23975 [Thread-39-disruptor-worker-transfer-queue] INFO backtype.storm.util - Async loop interrupted! 23976 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.worker - Shut down transfer thread 23977 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.worker - Shutting down default resources 23978 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.worker - Shut down default resources 24019 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.worker - Disconnecting from storm cluster state context 24021 [ProcessThread(sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor - Processed session termination for sessionid: 0x1 4b718b3a9b000b 24068 [storm.starter.WordCountTopology.main()] INFO org.apache.storm.zookeeper.ZooKeeper - Session: 0x14b718b3a9b000b closed 24068 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.worker - Shut down worker word-count-1-1423539127 fa5a41fd-431e-409a-91b0-9 8a52d5b72b8 1024 24068 [Thread-7-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn - EventThread shut down 24100 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN org.apache.storm.zookeeper.server.NIOServerCnxn - caught end of stream exception org.apache.storm.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x14b718b3a9b000b, likely clie nt has closed socket at org.apache.storm.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at org.apache.storm.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_65] 24102 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn - Closed socket connection for client /0:0:0:0 :0:0:0:1:55353 which had sessionid 0x14b718b3a9b000b ERROR: The process "10928" not found. 24338 [storm.starter.WordCountTopology.main()] INFO backtype.storm.util - Error when trying to kill 10928. Process is probably already dead. ERROR: The process "14812" not found. 24592 [storm.starter.WordCountTopology.main()] INFO backtype.storm.util - Error when trying to kill 14812. Process is probably already dead. ERROR: The process "6192" not found. 24854 [storm.starter.WordCountTopology.main()] INFO backtype.storm.util - Error when trying to kill 6192. Process is probably already dead. ERROR: The process "10928" not found. 26095 [storm.starter.WordCountTopology.main()] INFO backtype.storm.util - Error when trying to kill 10928. Process is probably already dead. ERROR: The process "14812" not found. 26355 [storm.starter.WordCountTopology.main()] INFO backtype.storm.util - Error when trying to kill 14812. Process is probably already dead. ERROR: The process "6192" not found. 26613 [storm.starter.WordCountTopology.main()] INFO backtype.storm.util - Error when trying to kill 6192. Process is probably already dead. 26649 [storm.starter.WordCountTopology.main()] INFO backtype.storm.config - REMOVE worker-user a68f7a64-4803-4384-aa32-3a7420d8819d 26651 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.supervisor - Shut down fa5a41fd-431e-409a-91b0-98a52d5b72b8:a68f7a64-4803-4 384-aa32-3a7420d8819d 26652 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.supervisor - Shutting down supervisor fa5a41fd-431e-409a-91b0-98a52d5b72b8 26654 [Thread-6] INFO backtype.storm.event - Event manager interrupted 26655 [Thread-7] INFO backtype.storm.event - Event manager interrupted 26657 [ProcessThread(sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor - Processed session termination for sessionid: 0x1 4b718b3a9b0007 26662 [storm.starter.WordCountTopology.main()] INFO org.apache.storm.zookeeper.ZooKeeper - Session: 0x14b718b3a9b0007 closed 26716 [storm.starter.WordCountTopology.main()-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn - EventThread shut down 26717 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN org.apache.storm.zookeeper.server.NIOServerCnxn - caught end of stream exception org.apache.storm.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x14b718b3a9b0007, likely clie nt has closed socket at org.apache.storm.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at org.apache.storm.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_65] 26717 [storm.starter.WordCountTopology.main()] INFO backtype.storm.daemon.supervisor - Shutting down supervisor 981998d1-e160-4aa1-aa68-4baa63ba293f 26720 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn - Closed socket connection for client /127.0.0 .1:55341 which had sessionid 0x14b718b3a9b0007 26721 [Thread-8] INFO backtype.storm.event - Event manager interrupted 26722 [Thread-9] INFO backtype.storm.event - Event manager interrupted 26724 [ProcessThread(sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor - Processed session termination for sessionid: 0x1 4b718b3a9b0009 26728 [storm.starter.WordCountTopology.main()] INFO org.apache.storm.zookeeper.ZooKeeper - Session: 0x14b718b3a9b0009 closed 26729 [storm.starter.WordCountTopology.main()] INFO backtype.storm.testing - Shutting down in process zookeeper 26728 [storm.starter.WordCountTopology.main()-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn - EventThread shut down 26730 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN org.apache.storm.zookeeper.server.NIOServerCnxn - caught end of stream exception org.apache.storm.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x14b718b3a9b0009, likely clie nt has closed socket at org.apache.storm.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at org.apache.storm.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-0.10.0-SNAPSHOT.jar:0.10.0-SNAPSHOT] at java.lang.Thread.run(Thread.java:745) [na:1.7.0_65] 26732 [storm.starter.WordCountTopology.main()] INFO org.apache.storm.zookeeper.server.NIOServerCnxn - Closed socket connection for client /0:0:0:0:0: 0:0:1:55347 which had sessionid 0x14b718b3a9b0009 26735 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory - NIOServerCnxn factory exited run meth od 26738 [storm.starter.WordCountTopology.main()] INFO org.apache.storm.zookeeper.server.ZooKeeperServer - shutting down 26738 [storm.starter.WordCountTopology.main()] INFO org.apache.storm.zookeeper.server.SessionTrackerImpl - Shutting down 26738 [storm.starter.WordCountTopology.main()] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor - Shutting down 26739 [storm.starter.WordCountTopology.main()] INFO org.apache.storm.zookeeper.server.SyncRequestProcessor - Shutting down 26740 [SyncThread:0] INFO org.apache.storm.zookeeper.server.SyncRequestProcessor - SyncRequestProcessor exited! 26739 [ProcessThread(sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor - PrepRequestProcessor exited loop! 26740 [storm.starter.WordCountTopology.main()] INFO org.apache.storm.zookeeper.server.FinalRequestProcessor - shutdown of request processor complete 26742 [storm.starter.WordCountTopology.main()] INFO backtype.storm.testing - Done shutting down in process zookeeper 26743 [storm.starter.WordCountTopology.main()] INFO backtype.storm.testing - Deleting temporary path C:\Users\jrgregg\AppData\Local\Temp\5f8dcdfe-dc0 0-4b6d-a80d-ec20d47c8519 26755 [storm.starter.WordCountTopology.main()] INFO backtype.storm.testing - Deleting temporary path C:\Users\jrgregg\AppData\Local\Temp\42494c0e-846 8-4f04-ac35-04da766f637f 26759 [storm.starter.WordCountTopology.main()] INFO backtype.storm.testing - Unable to delete file: C:\Users\jrgregg\AppData\Local\Temp\42494c0e-8468 -4f04-ac35-04da766f637f\version-2\log.1 26760 [storm.starter.WordCountTopology.main()] INFO backtype.storm.testing - Deleting temporary path C:\Users\jrgregg\AppData\Local\Temp\1368b5b7-29d 0-4793-a5e5-a32c2ed5793b 26809 [storm.starter.WordCountTopology.main()] INFO backtype.storm.testing - Deleting temporary path C:\Users\jrgregg\AppData\Local\Temp\8029dd9c-8e6 d-4dfc-911b-4f9a12243fdc 27006 [SessionTracker] INFO org.apache.storm.zookeeper.server.SessionTrackerImpl - SessionTrackerImpl exited loop! [INFO] ------------------------------------------------------------------------ [INFO] BUILD FAILURE [INFO] ------------------------------------------------------------------------ [INFO] Total time: 44.808 s [INFO] Finished at: 2015-02-09T22:32:22-05:00 [INFO] Final Memory: 31M/514M [INFO] ------------------------------------------------------------------------ [ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.2.1:java (default-cli) on project storm-starter: An exception occured while execu ting the Java class. java.lang.InterruptedException -> [Help 1] [ERROR] [ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch. [ERROR] Re-run Maven using the -X switch to enable full debug logging. [ERROR] [ERROR] For more information about the errors and possible solutions, please read the following articles: [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException On Mon, Feb 9, 2015 at 9:09 PM, Mike Clarke <[email protected]> wrote: > Do you get a bunch of other INFO-level output from > `backtype.storm.daemon.executor` prior to the exception? If you do, that > means everything is running for 10s properly, and the exception is thrown > at the very end when the cluster is shut down. There's a recent Stack > Overflow post that mentions this same exception > <https://stackoverflow.com/questions/26568767/storm-starter-example-topologies-crash> > . > > One possible workaround is to remove the call to `cluster.shutdown()` and > kill the java process manually when you want to stop running the local > cluster. > > On Mon, Feb 9, 2015 at 5:30 PM, Jon Gregg <[email protected]> wrote: > >> OK Mike's suggestion seemed to work, but on the very next line in the >> tutorial I ran mvn compile exec:java >> -Dstorm.topology=storm.starter.WordCountTopology from storm-starter and >> got his error: >> >> >> [ERROR] Failed to execute goal >> org.codehaus.mojo:exec-maven-plugin:1.2.1:java (d >> efault-cli) on project storm-starter: An exception occured while >> executing the J >> ava class. instance must be started before calling this method -> [Help 1] >> [ERROR] >> [ERROR] To see the full stack trace of the errors, re-run Maven with the >> -e swit >> ch. >> [ERROR] Re-run Maven using the -X switch to enable full debug logging. >> [ERROR] >> [ERROR] For more information about the errors and possible solutions, >> please rea >> d the following articles: >> [ERROR] [Help 1] >> http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionE >> xception >> >> >> I also tried with quotes around the final argument (I'm using Windows) >> and got the following: >> >> [ERROR] Failed to execute goal >> org.codehaus.mojo:exec-maven-plugin:1.2.1:java (d >> efault-cli) on project storm-starter: An exception occured while >> executing the J >> ava class. java.lang.InterruptedException -> [Help 1] >> [ERROR] >> [ERROR] To see the full stack trace of the errors, re-run Maven with the >> -e swit >> ch. >> [ERROR] Re-run Maven using the -X switch to enable full debug logging. >> [ERROR] >> [ERROR] For more information about the errors and possible solutions, >> please rea >> d the following articles: >> [ERROR] [Help 1] >> http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionE >> xception >> >> >> On Mon, Feb 9, 2015 at 7:30 PM, Andrew Xor <[email protected]> >> wrote: >> >>> No, this is actually one of the most common pitfalls (and subsequently >>> question) that we see here; you have to actually go to the pom.xml that is >>> located in storm-starter folder and change the dependency scope of >>> storm-core (which is the <scope> </scope> tag) from whatever it is to >>> "compile" (without the ""). This should (hopefully) solve your problem... >>> >>> Regards, >>> >>> A. >>> >>> On Tue, Feb 10, 2015 at 2:02 AM, Mike Clarke <[email protected]> >>> wrote: >>> >>>> It's likely you didn't run the mvn command from the top level "storm" >>>> directory, as it notes in the readme: >>>> >>>> ``` >>>> # Must be run from the top-level directory of the Storm code repository >>>> $ mvn clean install -DskipTests=true >>>> ``` >>>> >>>> Try re-running the `mvn clean install` command from the top-level of >>>> your checkout. Then, future `mvn` commands should be run from the >>>> examples/storm-starter directory if you're looking to try the example word >>>> count topologies. >>>> >>>> On Mon, Feb 9, 2015 at 3:52 PM, Jon Gregg <[email protected]> wrote: >>>> >>>>> I cloned storm-starter from >>>>> https://github.com/apache/storm/tree/master/examples/storm-starter, >>>>> then went to build my jar locally using "mvn clean install >>>>> -DskipTests=true" >>>>> >>>>> Here's the error I got: >>>>> >>>>> [ERROR] Failed to execute goal on project storm-starter: Could not >>>>> resolve depen >>>>> dencies for project >>>>> org.apache.storm:storm-starter:jar:0.10.0-SNAPSHOT: Could no >>>>> t find artifact org.apache.storm:storm-core:jar:0.10.0-SNAPSHOT in >>>>> clojars (http >>>>> s://clojars.org/repo/) -> [Help 1] >>>>> >>>>> Maybe I'm looking at the wrong location, but I don't see "storm" >>>>> listed at https://clojars.org/repo/org/apache/ >>>>> >>>>> How can I make this work? >>>>> >>>>> Jon >>>>> >>>>> >>>> >>> >> >
