Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-5285

CancelCheckpointMarker flood when using at least once mode

    Details

      Description

      When using at least once mode (BarrierTracker), then an interleaved arrival of cancellation barriers at the BarrierTracker of two consecutive checkpoints can trigger a flood of CancelCheckpointMarkers.

      The following sequence is problematic:

      Cancel(1, 0),
      Cancel(2, 0),
      Cancel(1, 1),
      Cancel(2, 1),
      Cancel(1, 2),
      Cancel(2, 2)
      

      with Cancel(checkpointId, channelId)

        Attachments

          Activity

            People

            • Assignee:
              till.rohrmann Till Rohrmann
              Reporter:
              till.rohrmann Till Rohrmann
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: