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)
