[jira] [Created] (FLINK-22638) Keep channels blocked on alignment timeout

[Shang Yuanchun (Jira)]

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)