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
