Aparna Ravindra created STORM-3672:
--------------------------------------
Summary: How does WindowedBoltExecutor handle FailedException?
Key: STORM-3672
URL: https://issues.apache.org/jira/browse/STORM-3672
Project: Apache Storm
Issue Type: Question
Reporter: Aparna Ravindra
After a tuple falls out of the window, the WindowedBoltExecutor does a
{{windowedOutputCollector.ack(tuple);}}. However, I could not find what happens
when {{boltExecute}} method throws a {{FailedException}}.
{{BasicBoltExecutor}} handles this explicitly like
([this|https://github.com/apache/storm/blob/e7731a547ae113d2fbc0fda6a9f02fc3d78de5fb/storm-client/src/jvm/org/apache/storm/topology/BasicBoltExecutor.java#L50]).
I could not find the equivalent handling for {{WindowedBoltExecutor}}. How are
the failed tuples handled? And how are retries managed? Thanks in advance.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
