[FLINK-21246] Decline Checkpoint if some tasks finished before get triggered

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.14.0
• Component/s: API / DataStream, Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Yun Gao
• Created: 03/Feb/21 07:27
• Updated: 14/Dec/21 09:06
• Resolved: 16/Jul/21 09:16

Description

When considering checkpoint while tasks get to finished, CheckpointCoordinator computes the tasks to trigger based on the current finish status, then during trigger, some more tasks might finished. In this case, CheckpointCoordinator would abort this checkpoint.

This is an replacement option to FLINK-21081

Issue Links

• relates to: FLINK-21081 Re-compute tasks to trigger when tasks get triggered before finished
• relates to: FLINK-23741 FLIP-147 Waiting for final checkpoint can deadlock job
• links to: GitHub Pull Request #16493