Hi milinda,
i am getting following error while running topology,
84329 [Thread-21-split] INFO backtype.storm.task.ShellBolt - Launched
subprocess with pid 7356
84331 [Thread-21-split] INFO backtype.storm.daemon.executor - Prepared
bolt split:(3)
84335 [Thread-23-spout] INFO backtype.storm.spout.ShellSpout - Launched
subprocess with pid 7360
84335 [Thread-23-spout] INFO backtype.storm.daemon.executor - Opened spout
spout:(4)
84337 [Thread-23-spout] INFO backtype.storm.daemon.executor - Processing
received message source: __system:-1, stream: __tick, id: {}, [30]
84338 [Thread-23-spout] INFO backtype.storm.daemon.executor - Processing
received message source: __system:-1, stream: __tick, id: {}, [30]
84339 [Thread-23-spout] INFO backtype.storm.daemon.executor - Activating
spout spout:(4)
84459 [Thread-19-count] ERROR backtype.storm.util - Async loop died!
java.lang.RuntimeException: Error when launching multilang subprocess
at backtype.storm.task.ShellBolt.prepare(ShellBolt.java:88)
~[storm-core-0.9.0.1.jar:na]
at
backtype.storm.daemon.executor$fn__3498$fn__3510.invoke(executor.clj:674)
~[storm-core-0.9.0.1.jar:na]
at backtype.storm.util$async_loop$fn__444.invoke(util.clj:401)
~[storm-core-0.9.0.1.jar:na]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
at java.lang.Thread.run(Thread.java:744) [na:1.7.0_51]
Caused by: java.io.IOException: unable to parse:
E_RUNFAILED_wordcount_admin_7354_ImportError
at backtype.storm.utils.ShellProcess.readMessage(ShellProcess.java:69)
~[storm-core-0.9.0.1.jar:na]
at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:45)
~[storm-core-0.9.0.1.jar:na]
at backtype.storm.task.ShellBolt.prepare(ShellBolt.java:85)
~[storm-core-0.9.0.1.jar:na]
... 4 common frames omitted
84460 [Thread-19-count] ERROR backtype.storm.daemon.executor -
java.lang.RuntimeException: Error when launching multilang subprocess
at backtype.storm.task.ShellBolt.prepare(ShellBolt.java:88)
~[storm-core-0.9.0.1.jar:na]
at
backtype.storm.daemon.executor$fn__3498$fn__3510.invoke(executor.clj:674)
~[storm-core-0.9.0.1.jar:na]
at backtype.storm.util$async_loop$fn__444.invoke(util.clj:401)
~[storm-core-0.9.0.1.jar:na]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
at java.lang.Thread.run(Thread.java:744) [na:1.7.0_51]
Caused by: java.io.IOException: unable to parse:
E_RUNFAILED_wordcount_admin_7354_ImportError
at backtype.storm.utils.ShellProcess.readMessage(ShellProcess.java:69)
~[storm-core-0.9.0.1.jar:na]
at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:45)
~[storm-core-0.9.0.1.jar:na]
at backtype.storm.task.ShellBolt.prepare(ShellBolt.java:85)
~[storm-core-0.9.0.1.jar:na]
... 4 common frames omitted
84646 [Thread-19-count] INFO backtype.storm.util - Halting process:
("Worker died")
Error on or near line 24; exiting with status 1
On Tue, Mar 18, 2014 at 9:44 PM, Milinda Pathirage <[email protected]>wrote:
> Hi Yogesh,
>
> Its better if you can share the error you got. It will be easy for
> someone to help you by looking at the error log.
>
> Thanks
> Milinda
>
> On Tue, Mar 18, 2014 at 11:50 AM, yogesh panchal <[email protected]>
> wrote:
> > Hi,
> >
> > I am new in storm, I am using https://github.com/AirSage/Petrel library
> to
> > write storm topology in python, i have successfully run wordcount example
> > written in python, but i now i want to insert output of "WordCountBolt"
> to
> > mysql database. Following example i am trying but i am getting weird
> error,
> > Please check wordcount.py here,
> https://gist.github.com/yspanchal/9618638
> >
> >
> >
> > --
> > Thanks & Regards
> >
> > Yogesh Panchal
> >
> >
>
>
>
> --
> Milinda Pathirage
>
> PhD Student | Research Assistant
> School of Informatics and Computing | Data to Insight Center
> Indiana University
>
> twitter: milindalakmal
> skype: milinda.pathirage
> blog: http://milinda.pathirage.org
>
--
Thanks & Regards
Yogesh Panchal
>>> If You Go Black There is No Other Way to Come Back ........!
