The error message points you in the right direction: "No module named spouts"
It seems like you are trying to use a module called "spouts" that doesn't exist. Is it supposed to be "Spout" instead? If that doesn't work can you send on a gist of the script that is causing this issue? Mark On 18 May 2015 at 07:17, Technical Presentation Course Student Group < [email protected]> wrote: > Hi, > Here am failed to run storm cluster after a while. > > *please help me* how to write fix this problem > > Does some body have any idea about the following error in the cluster? > > java.lang.RuntimeException: Error when launching multilang subprocess > /app/storm/supervisor/stormdist/DRC-4-1431914407/resources/pyleus_venv/bin/python: > No module named spouts > > at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:64) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at backtype.storm.spout.ShellSpout.open(ShellSpout.java:54) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > backtype.storm.daemon.executor$fn__5573$fn__5588.invoke(executor.clj:520) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at backtype.storm.util$async_loop$fn__457.invoke(util.clj:429) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at clojure.lang.AFn.run(AFn.java:24) ~[clojure-1.5.1.jar:na] > at java.lang.Thread.run(Thread.java:701) ~[na:1.6.0_35] > Caused by: java.io.EOFException: null > at org.msgpack.io.StreamInput.readByte(StreamInput.java:60) > ~[stormjar.jar:na] > at > org.msgpack.unpacker.MessagePackUnpacker.getHeadByte(MessagePackUnpacker.java:66) > ~[stormjar.jar:na] > at > org.msgpack.unpacker.MessagePackUnpacker.trySkipNil(MessagePackUnpacker.java:396) > ~[stormjar.jar:na] > at org.msgpack.template.MapTemplate.read(MapTemplate.java:59) > ~[stormjar.jar:na] > at org.msgpack.template.MapTemplate.read(MapTemplate.java:27) > ~[stormjar.jar:na] > at org.msgpack.template.AbstractTemplate.read(AbstractTemplate.java:31) > ~[stormjar.jar:na] > at org.msgpack.MessagePack.read(MessagePack.java:527) ~[stormjar.jar:na] > at org.msgpack.MessagePack.read(MessagePack.java:496) ~[stormjar.jar:na] > at > com.yelp.pyleus.serializer.MessagePackSerializer.readMessage(MessagePackSerializer.java:198) > ~[stormjar.jar:na] > at > com.yelp.pyleus.serializer.MessagePackSerializer.connect(MessagePackSerializer.java:67) > ~[stormjar.jar:na] > at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:62) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > ... 5 common frames omitted > 2015-05-18 06:33:33 b.s.util [ERROR] Async loop died! > java.lang.RuntimeException: java.lang.RuntimeException: > java.io.EOFException > at > backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:128) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:99) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:80) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > backtype.storm.daemon.executor$fn__5641$fn__5653$fn__5700.invoke(executor.clj:746) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at backtype.storm.util$async_loop$fn__457.invoke(util.clj:431) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at clojure.lang.AFn.run(AFn.java:24) ~[clojure-1.5.1.jar:na] > at java.lang.Thread.run(Thread.java:701) ~[na:1.6.0_35] > Caused by: java.lang.RuntimeException: java.io.EOFException > at backtype.storm.task.ShellBolt.execute(ShellBolt.java:157) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > backtype.storm.daemon.executor$fn__5641$tuple_action_fn__5643.invoke(executor.clj:631) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > backtype.storm.daemon.executor$mk_task_receiver$fn__5564.invoke(executor.clj:399) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > backtype.storm.disruptor$clojure_handler$reify__745.onEvent(disruptor.clj:58) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at > backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:125) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > ... 6 common frames omitted > Caused by: java.io.EOFException: null > at org.msgpack.io.StreamInput.readByte(StreamInput.java:60) > ~[stormjar.jar:na] > at > org.msgpack.unpacker.MessagePackUnpacker.getHeadByte(MessagePackUnpacker.java:66) > ~[stormjar.jar:na] > at > org.msgpack.unpacker.MessagePackUnpacker.trySkipNil(MessagePackUnpacker.java:396) > ~[stormjar.jar:na] > at org.msgpack.template.MapTemplate.read(MapTemplate.java:59) > ~[stormjar.jar:na] > at org.msgpack.template.MapTemplate.read(MapTemplate.java:27) > ~[stormjar.jar:na] > at org.msgpack.template.AbstractTemplate.read(AbstractTemplate.java:31) > ~[stormjar.jar:na] > at org.msgpack.MessagePack.read(MessagePack.java:527) ~[stormjar.jar:na] > at org.msgpack.MessagePack.read(MessagePack.java:496) ~[stormjar.jar:na] > at > com.yelp.pyleus.serializer.MessagePackSerializer.readMessage(MessagePackSerializer.java:198) > ~[stormjar.jar:na] > at > com.yelp.pyleus.serializer.MessagePackSerializer.readShellMsg(MessagePackSerializer.java:74) > ~[stormjar.jar:na] > at backtype.storm.utils.ShellProcess.readShellMsg(ShellProcess.java:97) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > at backtype.storm.task.ShellBolt$1.run(ShellBolt.java:107) > ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] > ... 1 common frames omitted > 2015-05-18 06:33:33 b.s.d.executor [ERROR] > >
