[FLINK-21081] Re-compute tasks to trigger when tasks get triggered before finished

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Later
• Component/s: API / DataStream, Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Yun Gao
• Created: 22/Jan/21 01:29
• Updated: 08/Oct/21 11:14
• Resolved: 09/Mar/21 09:28

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 need to re-compute tasks to trigger and re-trigger the newly involved tasks. 

This is a replacement option to FLINK-21246

Issue Links

• is related to: FLINK-21246 Decline Checkpoint if some tasks finished before get triggered
• links to: GitHub Pull Request #14818