You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by Binita Bharati <bi...@gmail.com> on 2014/10/15 19:41:13 UTC

Storm Spout FAIL not invoked

Hi all,

According to the link :
https://storm.incubator.apache.org/documentation/Guaranteeing-message-processing.html
,

A tuple is considered failed, if it fails to be processed within the
Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS
<https://storm.incubator.apache.org/apidocs/backtype/storm/Config.html#TOPOLOGY_MESSAGE_TIMEOUT_SECS>
configuration
that defaults to 30 seconds.

I have made my tuple processing in the Bolt to be slower than 30 secs
(using Thread.sleep )
But, the Spout's "fail" method never gets invoked. Also, I have used
anchored emits in the Spout using :

collector.emit(new Values(emitWord), msgId);

The Bolt thread is waking up from sleep in 60 secs , but, the Spout's fail
method never gets invoked. What am I missing ?
Thanks
-Binita