I have written my own simple Spout extending from ITridentSpout. This Spout has its own simple implementation of Emitter and BatchCoordinator.
I am trying to determine if a batch is replayed via the log statements in the Emitter. Am printing the transactionId , and the emitted tuple details from the emitBatch function.So, am expecting to see the log statement for the same transactionId and tuple more than once. But, I do not see that. On Sat, Oct 25, 2014 at 1:13 AM, P. Taylor Goetz <[email protected]> wrote: > What Trident spout are you using? How are you determining whether a batch > is being replayed or not? > > -Taylor > > On Oct 24, 2014, at 6:23 AM, Binita Bharati <[email protected]> > wrote: > > > I am throwing a backtype.storm.topology.FailedException from my Trident > Function. But , I don't see the batch being replayed ? > > > > What am I missing ? > > > > -Binita > >
