[FLINK-21086] Support checkpoint alignment with finished input channels

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.14.0
• Component/s: API / DataStream, Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Yun Gao
• Reporter: Yun Gao
• Created: 22/Jan/21 03:51
• Updated: 23/Sep/21 17:55
• Resolved: 02/Jul/21 16:01

Description

For a non-source task, if one of its precedent task has finished, the precedent task would send EndOfPartition to it. However, currently the CheckpointBarrierHandler could not support receiving EndOfPartitionEvent. To support checkpoint after some tasks finish, when received EndOfPartitionEvent the CheckpointBarrierHandler should

1.  For all the pending checkpoints, mark this channel as aligned.
2. For the future checkpoints, excludes this channel.

Issue Links

• links to: GitHub Pull Request #14831
• links to: GitHub Pull Request #15055