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
