You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by Andrew Neilson <ar...@gmail.com> on 2014/05/15 22:45:23 UTC

Received commit for different transaction attempt

Could someone help me understand the context under which this error might
occur? I'm seeing this pop up in one of our topologies running with Trident
on Storm v0.9.0.1 and it is unable to recover once this happens.

java.lang.RuntimeException: backtype.storm.topology.FailedException:
Received commit for different transaction attempt
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:90)
at
backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:61)
at
backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:62)
at
backtype.storm.daemon.executor$fn__3498$fn__3510$fn__3557.invoke(executor.clj:730)
at backtype.storm.util$async_loop$fn__444.invoke(util.clj:403) at
clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Thread.java:662)

Caused by: backtype.storm.topology.FailedException: Received commit for
different transaction attempt
at
storm.trident.spout.TridentSpoutExecutor.execute(TridentSpoutExecutor.java:56)
at
storm.trident.topology.TridentBoltExecutor.execute(TridentBoltExecutor.java:297)
at
backtype.storm.daemon.executor$fn__3498$tuple_action_fn__3500.invoke(executor.clj:615)
at
backtype.storm.daemon.executor$mk_task_receiver$fn__3421.invoke(executor.clj:383)
at
backtype.storm.disruptor$clojure_handler$reify__2962.onEvent(disruptor.clj:43)
at
backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:87)
... 6 more

Thanks,
Andrew