You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by sam mohel <sa...@gmail.com> on 2017/06/13 03:49:34 UTC
DRPCExecutionException !
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
Re: DRPCExecutionException !
Posted by sam mohel <sa...@gmail.com>.
is there any help , please ?
On Tue, Jun 13, 2017 at 5:49 AM, sam mohel <sa...@gmail.com> wrote:
> 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
>
Re: DRPCExecutionException !
Posted by sam mohel <sa...@gmail.com>.
is there any help , please ?
On Tue, Jun 13, 2017 at 5:49 AM, sam mohel <sa...@gmail.com> wrote:
> 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
>