Guys,
i am a bit confused about the fault tolerance feature of storm. I have read
https://storm.incubator.apache.org/documentation/Guaranteeing-message-processing.html

My question is, if a bolt failed with some runtime exception, does it means
that the tuple is failed and the same tuple sent to this bolt will be
replayed again? Or it means that the message has been processed although it
failed. It already met the "at least one" processing, and will not be
replayed.
Or it depends on how and when I call .ack and .fail?

Also about replaying message if time out, does it mean that if a downstream
bolt takes more than the specified time out, the message will be replayed?
Or its again depending on when I call ack and fail..

Thanks for clarification.
Chen

Reply via email to