Hi,
Storm: 0.9.2-incubating
I'm running some DRPC tests with a Local Storm instance, and with some data
I'm processing, I get the following error:
DRPCExecutionException(msg:Request failed)
at
backtype.storm.daemon.drpc$service_handler$reify__5501.failRequest(drpc.clj:113)
at backtype.storm.drpc.DRPCSpout.fail(DRPCSpout.java:159)
at
storm.trident.spout.RichSpoutBatchTriggerer.fail(RichSpoutBatchTriggerer.java:106)
at
backtype.storm.daemon.executor$fail_spout_msg.invoke(executor.clj:370)
at
backtype.storm.daemon.executor$fn$reify__3287.expire(executor.clj:430)
at backtype.storm.utils.RotatingMap.rotate(RotatingMap.java:73)
at
backtype.storm.daemon.executor$fn__3284$tuple_action_fn__3290.invoke(executor.clj:435)
at
backtype.storm.daemon.executor$mk_task_receiver$fn__3275.invoke(executor.clj:402)
at
backtype.storm.disruptor$clojure_handler$reify__1437.onEvent(disruptor.clj:58)
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:125)
at
backtype.storm.utils.DisruptorQueue.consumeBatch(DisruptorQueue.java:87)
at backtype.storm.disruptor$consume_batch.invoke(disruptor.clj:76)
at
backtype.storm.daemon.executor$fn__3284$fn__3299$fn__3328.invoke(executor.clj:540)
at backtype.storm.util$async_loop$fn__452.invoke(util.clj:431)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:745)
I can reprocess the data, and sometime, I get a result, but other times I
do get this exception.
It's not very clear what is happening here. Is it something as simple as
the DRPC execution is taking too long? (entirely possible, they can be
somewhat long running, and the exception doesn't get thrown until after a
while)
I wondered if it was some sort of OOM issue, but there was no log of that,
and watching in jconsole gives no indication.
Any help pointing me to what is happening here would be greatly appreciated.
Mark
--
E: mark.man...@gmail.com
T: http://www.twitter.com/neurotic
W: www.compoundtheory.com
2 Devs from Down Under Podcast
http://www.2ddu.com/
