Sudheer, Latest change to R-Storm package was to support 0.9.3 release. There was a change in Storm multilang protocol in 0.9.3 that broke backward compatibility. I'm not sure if that change in R-Storm is causing things to fail in Storm 0.9.0. Will you be able to give it a try with upgraded Storm version?
You could also include Storm.R directly in your project. This way you can add more logging in R-Storm code to figure out what went wrong. Srikanth On Mon, Sep 7, 2015 at 7:11 AM, Sudheer Reddy <[email protected]> wrote: > I’m trying to integrate R as a bolt with in my Storm topology. > > I’m following https://github.com/allenday/R-Storm (Write Storm Bolts in R > using the Storm Multi-Language Protocol). > > When I try example PermuteTopology.java there, I’m getting the following > error: > > 5497 [Thread-16] INFO backtype.storm.daemon.executor - Processing > received message source: spout:3, stream: default, id: {}, [the cow jumped > over the moon] > > 15082 [Thread-18] INFO backtype.storm.daemon.task - Emitting: spout > default [an apple a day keeps the doctor away] > > 15082 [Thread-16] INFO backtype.storm.daemon.executor - Processing > received message source: spout:3, stream: default, id: {}, [an apple a day > keeps the doctor away] > > 15082 [Thread-16] ERROR backtype.storm.util - Async loop died! > > *java.lang.RuntimeException*: *java.lang.RuntimeException*: > *java.lang.RuntimeException*: Pipe to subprocess seems to be broken! No > output read. > > Shell Process Exception: > > > > > > at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor( > *DisruptorQueue.java:87*) ~[storm-0.9.0-wip16.jar:na] > > at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable( > *DisruptorQueue.java:58*) ~[storm-0.9.0-wip16.jar:na] > > at > backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:62) > ~[storm-0.9.0-wip16.jar:na] > > at > backtype.storm.daemon.executor$fn__3557$fn__3569$fn__3616.invoke(executor.clj:715) > ~[storm-0.9.0-wip16.jar:na] > > at backtype.storm.util$async_loop$fn__436.invoke(util.clj:377) > ~[storm-0.9.0-wip16.jar:na] > > at clojure.lang.AFn.run(*AFn.java:24*) [clojure-1.4.0.jar:na] > > at java.lang.Thread.run(*Thread.java:745*) [na:1.7.0_80] > > > > > > > > My R is setup well, it has the dependent R libraries already installed. > > > > > > Any help on this please? > > > > Thanks > > Sudheer >
