Hi All, I am playing with a trident topology having a single spout. The topology simply counts the words emitted and stores it in redis [1]. I run this on 4 worker nodes.
I deliberately shutdown one worker node and restart it and monitor the batch replay (I am logging the transaction id of the batches being emitted). I see the last batch which didn't complete before the shutdown gets re-emitted again and again without succeeding. Any idea why this happens? (I created the spout implementing `ITridentSpout`.) Thanks in advance for any explanation on this. [1] http://redis.io/ Regards, Thilina
