Uploaded image for project: 'Apache Storm'
  1. Apache Storm
  2. STORM-1859

Late tuples are not acked in windowed mode

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.0.0, 1.0.2, 1.1.0
    • Component/s: None
    • Labels:
      None

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

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                kosii Balazs Kossovics
                Reporter:
                kosii Balazs Kossovics
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: