RuntimeException: unexpected tuple source

Mon, 16 Jun 2014 05:07:20 -0700 

Hi all,

Can someone tell me, what is the reason of this exception??

java.lang.RuntimeException: java.lang.RuntimeException: Received unexpected 
tuple source: $mastercoord-bg5:4, stream: $commit, id: 
{-325565218700865050=6198405391722663141}, [1:17]
        at 
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:107)
        at 
backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:78)
        at 
backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:77)
        at 
backtype.storm.daemon.executor$eval3918$fn__3919$fn__3931$fn__3978.invoke(executor.clj:745)
        at backtype.storm.util$async_loop$fn__384.invoke(util.clj:433)
        at clojure.lang.AFn.run(AFn.java:24)
        at java.lang.Thread.run(Unknown Source)
Caused by: java.lang.RuntimeException: Received unexpected tuple source: 
$mastercoord-bg5:4, stream: $commit, id: 
{-325565218700865050=6198405391722663141}, [1:17]
        at 
storm.trident.planner.SubtopologyBolt.execute(SubtopologyBolt.java:144)
        at 
storm.trident.topology.TridentBoltExecutor.execute(TridentBoltExecutor.java:369)
        at 
backtype.storm.daemon.executor$eval3918$fn__3919$tuple_action_fn__3921.invoke(executor.clj:630)
        at 
backtype.storm.daemon.executor$mk_task_receiver$fn__3839.invoke(executor.clj:398)
        at 
backtype.storm.disruptor$clojure_handler$reify__1560.onEvent(disruptor.clj:58)
        at 
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:104)
        ... 6 more
How can I solve this??


Thanks!

Regards,

Andrés

Reply via email to