Arvid Heise created FLINK-18139: ----------------------------------- Summary: Unaligned checkpoints checks wrong channels for inflight data. Key: FLINK-18139 URL: https://issues.apache.org/jira/browse/FLINK-18139 Project: Flink Issue Type: Improvement Components: Runtime / Checkpointing Affects Versions: 1.11.0, 1.12.0 Reporter: Arvid Heise Assignee: Arvid Heise
CheckpointBarrierUnaligner#hasInflightData is not called with input gate contextual information, such that only the same first few channels are checked during initial snapshotting of inflight data. -- This message was sent by Atlassian Jira (v8.3.4#803005)