The issue is resolved now. The nextTuple method in my Spout had a call to backtype.storm.utils.Utils.sleep method - I removed that. Also, I explicitly set the TOPOLOGY_MESSAGE_TIMEOUT_SECS by doing a conf.setMessageTimeoutSecs(conf, 20);
On Thu, Oct 16, 2014 at 12:54 PM, Binita Bharati <[email protected]> wrote: > Hi all, > > I have the following simple topology: > > Spout1 -> Bolt1 > > 1)Spout1 > - emits anchored tuples ( collector.emit(new Values(emitWord), msgId); ) > - overrides fail method in BaseRichSpout. > > 2)Bolt1 > -delays the processing of the received tuple by invoking a Thread.sleep > > Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS. > > I expected the tuples to timeout and the fail method in Spout1 to be > invoked. > But, fail method never gets invoked. What am I missing ? > > -Binita > > >
