Anyone?
On Wed, Mar 19, 2014 at 12:03 PM, Srinath C <[email protected]> wrote: > Hi, > I'm facing an issue with acknowledgement of tuples. > > My topology has a spout (BaseRichSpout) that picks a message from RabbitMQ > and emits it with the deliveryTag as the message Id. The tuple is then > received by a bolt (BaseRichBolt) which processes the tuple. There are > other spouts and bolts but not participating in the flow that I'm talking > about. > > But in the simple case that I tried, the bolt is simply acknowledging the > tuple and I'm sure that there are no exceptions in the processing of the > tuple in the Bolt but the Spout is receiving a call to fail the tuple. The > fail() method is being invoked > from backtype.storm.utils.RotatingMap#rotate. The fail is getting called > almost immediately. > > This is happening even if topology.message.timeout.secs is set to 30. > > Any ideas in troubleshooting is greatly appreciated. What kind of logs > will help in troubleshooting? > PS: The ACK is working fine on a simplified topology with just one Spout > and one Bolt doing. > > Thanks, > Srinath. > >
