Balazs Kossovics created STORM-1859:
---------------------------------------

             Summary: Late tuples are not acked in windowed mode
                 Key: STORM-1859
                 URL: https://issues.apache.org/jira/browse/STORM-1859
             Project: Apache Storm
          Issue Type: Bug
            Reporter: Balazs Kossovics


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).




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to