I tried to run my topology in local mode but got
[WARNING]
DRPCExecutionException(msg:Request failed)
at
backtype.storm.daemon.drpc$service_handler$reify__5668.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:378)
at backtype.storm.daemon.executor$fn$reify__3374.expire(executor.clj:447)
at backtype.storm.utils.RotatingMap.rotate(RotatingMap.java:73)
at
backtype.storm.daemon.executor$fn__3371$tuple_action_fn__3377.invoke(executor.clj:452)
at
backtype.storm.daemon.executor$mk_task_receiver$fn__3362.invoke(executor.clj:410)
at
backtype.storm.disruptor$clojure_handler$reify__1445.onEvent(disruptor.clj:58)
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:132)
at backtype.storm.utils.DisruptorQueue.consumeBatch(DisruptorQueue.java:91)
at backtype.storm.disruptor$consume_batch.invoke(disruptor.clj:76)
at
backtype.storm.daemon.executor$fn__3371$fn__3386$fn__3415.invoke(executor.clj:549)
at backtype.storm.util$async_loop$fn__460.invoke(util.clj:463)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:745)

Any help will be appreciate

Reply via email to