Dawid Wysakowicz created FLINK-22638: ----------------------------------------
Summary: Keep channels blocked on alignment timeout Key: FLINK-22638 URL: https://issues.apache.org/jira/browse/FLINK-22638 Project: Flink Issue Type: Improvement Components: Runtime / Checkpointing Reporter: Dawid Wysakowicz Assignee: Dawid Wysakowicz Fix For: 1.14.0 In order to improve checkpointing time we could keep channels blocked in case an alignment timeout occurs. That way we prioritize the channels that we have not received the barrier yet. This solution is based on the assumption that all upstream operators are working with aligned checkpoints and we do not mind delaying the subsequent checkpoints on the blocked channels. -- This message was sent by Atlassian Jira (v8.3.4#803005)