Skip to content

Instantly share code, notes, and snippets.

@xumingming
Created April 20, 2012 17:37
Show Gist options
  • Save xumingming/2430530 to your computer and use it in GitHub Desktop.
Save xumingming/2430530 to your computer and use it in GitHub Desktop.
Storm Integration Test Error(3)
eeper.retry.interval" 1000, "supervisor.slots.ports" (4 5 6), "topology.debug" true, "nimbus.task.launch.secs" 120, "nimbus.supervisor.timeout.secs" 60, "topology.kryo.register" nil, "topology.message.timeout.secs" 3, "task.refresh.poll.secs" 10, "topology.workers" 20, "supervisor.childopts" "-Xmx1024m", "nimbus.thrift.port" 6627, "topology.stats.sample.rate" 0.05, "worker.heartbeat.frequency.secs" 1, "nimbus.task.timeout.secs" 30, "drpc.invocations.port" 3773, "zmq.threads" 1, "storm.zookeeper.retry.times" 5, "topology.state.synchronization.timeout.secs" 60, "supervisor.worker.timeout.secs" 30, "nimbus.file.copy.expiration.secs" 600, "drpc.request.timeout.secs" 600, "storm.local.mode.zmq" false, "ui.port" 8080, "nimbus.childopts" "-Xmx1024m", "topology.ackers" 1, "storm.cluster.mode" "local", "topology.optimize" false, "topology.max.task.parallelism" nil}
35817 [Thread-182] INFO backtype.storm.daemon.worker - Worker e2d7e923-be97-48f9-b4e6-e228460a190c for storm test-1-1334943321 on 444bee85-942d-486b-9ef7-96475211869e:4 has finished loading
35819 [Thread-187] INFO backtype.storm.daemon.task - Emitting: 2 __system ["startup"]
35819 [Thread-187] INFO backtype.storm.daemon.task - Preparing bolt 2:1
35827 [Thread-192] INFO backtype.storm.daemon.task - Emitting: 1 __system ["startup"]
35828 [Thread-192] INFO backtype.storm.daemon.task - Opening spout 1:3
35878 [Thread-187] ERROR backtype.storm.daemon.task -
java.lang.RuntimeException: Pipe to subprocess seems to be broken!
at backtype.storm.utils.ShellProcess.readString(ShellProcess.java:73)
at backtype.storm.utils.ShellProcess.readMessage(ShellProcess.java:57)
at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:38)
at backtype.storm.task.ShellBolt.prepare(ShellBolt.java:76)
at backtype.storm.daemon.task$fn__3552.invoke(task.clj:472)
at clojure.lang.MultiFn.invoke(MultiFn.java:206)
at backtype.storm.daemon.task$mk_task$fn__3410.invoke(task.clj:243)
at backtype.storm.daemon.task$mk_task.invoke(task.clj:242)
at backtype.storm.daemon.worker$fn__3684$exec_fn__1026__auto____3685$iter__3733__3737$fn__3738$fn__3739.invoke(worker.clj:178)
at backtype.storm.daemon.worker$fn__3684$exec_fn__1026__auto____3685$iter__3733__3737$fn__3738.invoke(worker.clj:178)
at clojure.lang.LazySeq.sval(LazySeq.java:42)
at clojure.lang.LazySeq.seq(LazySeq.java:56)
at clojure.lang.RT.seq(RT.java:450)
at clojure.core$seq.invoke(core.clj:122)
at clojure.core$dorun.invoke(core.clj:2450)
at clojure.core$doall.invoke(core.clj:2465)
at backtype.storm.daemon.worker$fn__3684$exec_fn__1026__auto____3685.invoke(worker.clj:178)
at clojure.lang.AFn.applyToHelper(AFn.java:187)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:540)
at backtype.storm.daemon.worker$fn__3684$mk_worker__3829.doInvoke(worker.clj:67)
at clojure.lang.RestFn.invoke(RestFn.java:513)
at backtype.storm.daemon.supervisor$fn__4321.invoke(supervisor.clj:420)
at clojure.lang.MultiFn.invoke(MultiFn.java:188)
at backtype.storm.daemon.supervisor$fn__4079$exec_fn__1026__auto____4080$sync_processes__4084$iter__4141__4145$fn__4146.invoke(supervisor.clj:236)
at clojure.lang.LazySeq.sval(LazySeq.java:42)
at clojure.lang.LazySeq.seq(LazySeq.java:56)
at clojure.lang.RT.seq(RT.java:450)
at clojure.core$seq.invoke(core.clj:122)
at clojure.core$dorun.invoke(core.clj:2450)
at clojure.core$doall.invoke(core.clj:2465)
at backtype.storm.daemon.supervisor$fn__4079$exec_fn__1026__auto____4080$sync_processes__4084.invoke(supervisor.clj:223)
at backtype.storm.event$event_manager$fn__2331.invoke(event.clj:24)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:679)
35918 [Thread-192] ERROR backtype.storm.daemon.task -
java.lang.RuntimeException: Pipe to subprocess seems to be broken!
at backtype.storm.utils.ShellProcess.readString(ShellProcess.java:73)
at backtype.storm.utils.ShellProcess.readMessage(ShellProcess.java:57)
at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:38)
at backtype.storm.spout.ShellSpout.open(ShellSpout.java:35)
at backtype.storm.daemon.task$fn__3472.invoke(task.clj:355)
at clojure.lang.MultiFn.invoke(MultiFn.java:206)
at backtype.storm.daemon.task$mk_task$fn__3410.invoke(task.clj:243)
at backtype.storm.daemon.task$mk_task.invoke(task.clj:242)
at backtype.storm.daemon.worker$fn__3684$exec_fn__1026__auto____3685$iter__3733__3737$fn__3738$fn__3739.invoke(worker.clj:178)
at backtype.storm.daemon.worker$fn__3684$exec_fn__1026__auto____3685$iter__3733__3737$fn__3738.invoke(worker.clj:178)
at clojure.lang.LazySeq.sval(LazySeq.java:42)
at clojure.lang.LazySeq.seq(LazySeq.java:56)
at clojure.lang.RT.seq(RT.java:450)
at clojure.core$seq.invoke(core.clj:122)
at clojure.core$dorun.invoke(core.clj:2450)
at clojure.core$doall.invoke(core.clj:2465)
at backtype.storm.daemon.worker$fn__3684$exec_fn__1026__auto____3685.invoke(worker.clj:178)
at clojure.lang.AFn.applyToHelper(AFn.java:187)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:540)
at backtype.storm.daemon.worker$fn__3684$mk_worker__3829.doInvoke(worker.clj:67)
at clojure.lang.RestFn.invoke(RestFn.java:513)
at backtype.storm.daemon.supervisor$fn__4321.invoke(supervisor.clj:420)
at clojure.lang.MultiFn.invoke(MultiFn.java:188)
at backtype.storm.daemon.supervisor$fn__4079$exec_fn__1026__auto____4080$sync_processes__4084$iter__4141__4145$fn__4146.invoke(supervisor.clj:236)
at clojure.lang.LazySeq.sval(LazySeq.java:42)
at clojure.lang.LazySeq.seq(LazySeq.java:56)
at clojure.lang.RT.seq(RT.java:450)
at clojure.core$seq.invoke(core.clj:122)
at clojure.core$dorun.invoke(core.clj:2450)
at clojure.core$doall.invoke(core.clj:2465)
at backtype.storm.daemon.supervisor$fn__4079$exec_fn__1026__auto____4080$sync_processes__4084.invoke(supervisor.clj:223)
at backtype.storm.event$event_manager$fn__2331.invoke(event.clj:24)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:679)
35965 [Thread-187] INFO backtype.storm.util - Halting process: ("Task died")
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment