[FLINK-22638] Keep channels blocked on alignment timeout

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.14.0, 1.13.2
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 11/May/21 16:01
• Updated: 28/Aug/21 12:11
• Resolved: 21/May/21 11:07

Description

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.

Issue Links

• links to: GitHub Pull Request #15897