storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jon Gregg <jonrgr...@gmail.com>
Subject Re: Error in storm-starter: Could not find artifact 0.10.0-SNAPSHOT in clojars
Date Tue, 10 Feb 2015 03:37:39 GMT
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 <mike.k.clarke@gmail.com> 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 <jonrgregg@gmail.com> 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 <andreas.grammenos@gmail.com>
>> 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 <mike.k.clarke@gmail.com>
>>> 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 <jonrgregg@gmail.com> 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
>>>>>
>>>>>
>>>>
>>>
>>
>

Mime
View raw message