I have a topology, that looks like
*All Bolts emits Fields "id", "json"*
*Spout emits only id*
*All bolts/spout uses the stream _stream name while emitting*
*Topology Definition*
*==*
builder.setSpout("citySpout", citySpout,10);
builder.setBolt("impactBol
Got the issue resolved.
1. I was not Anchoring to incoming tuple...so effectively, all the Bolts
after impactBolt , were not transactional. The ack of impact bolt was
causing spout's ack to be called. Proper DAG was not created. So the
number I was seeing in WIP was not the true number of tuples t
