[STORM-1859] Late tuples are not acked in windowed mode

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.0.0, 1.0.2, 1.1.0
• Epic Link: Release Apache Storm 1.0.2
• Assignee: Balazs Kossovics
• Reporter: Balazs Kossovics
• Created: 23/May/16 08:24
• Updated: 10/Jun/16 22:13
• Resolved: 25/May/16 16:00

Description

The current implementation simply ignores late tuples without acking
them, which causes timeouts and replays after
TOPOLOGY_MESSAGE_TIMEOUT_SECS. A tuple which was late at a some time
is going to be late at any moment in the future, so there is no point
of replaying it, because the lingering late tuples will just block the
topology (especially if TOPOLOGY_MAX_SPOUT_PENDING is set).

Issue Links

• links to: GitHub Pull Request #1437