Apache Storm: How does WindowedBoltExecutor handle FailedException?

Viewed 37

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. I could not find the equivalent handling for WindowedBoltExecutor. How are the failed tuples handled? Thanks in advance.

0 Answers
Related