[ https://issues.apache.org/jira/browse/FLINK-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Till Rohrmann closed FLINK-5285. -------------------------------- Resolution: Fixed Fixed in 1.2.0 via d3f19a5bead1d0709da733b75d729afa9341c250 Fixed in 1.1.4 via afaa27e9faeb0352a49f30de90e719572caa97c5 > CancelCheckpointMarker flood when using at least once mode > ---------------------------------------------------------- > > Key: FLINK-5285 > URL: https://issues.apache.org/jira/browse/FLINK-5285 > Project: Flink > Issue Type: Bug > Components: State Backends, Checkpointing > Affects Versions: 1.2.0, 1.1.3 > Reporter: Till Rohrmann > Assignee: Till Rohrmann > Fix For: 1.2.0, 1.1.4 > > > 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: > {code} > Cancel(1, 0), > Cancel(2, 0), > Cancel(1, 1), > Cancel(2, 1), > Cancel(1, 2), > Cancel(2, 2) > {code} > with {{Cancel(checkpointId, channelId)}} -- This message was sent by Atlassian JIRA (v6.3.4#6332)