[jira] [Created] (FLINK-21081) Re-compute tasks to trigger when tasks get triggered before finished

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-21081) Re-compute tasks to trigger when tasks get triggered before finished

Shang Yuanchun (Jira)
Yun Gao created FLINK-21081:
-------------------------------

             Summary: Re-compute tasks to trigger when tasks get triggered before finished
                 Key: FLINK-21081
                 URL: https://issues.apache.org/jira/browse/FLINK-21081
             Project: Flink
          Issue Type: Sub-task
            Reporter: Yun Gao


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 message was sent by Atlassian Jira
(v8.3.4#803005)