storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andrew Neilson <arsneil...@gmail.com>
Subject Received commit for different transaction attempt
Date Thu, 15 May 2014 20:45:23 GMT
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

Mime
View raw message