You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2021/01/22 01:30:00 UTC
[jira] [Created] (FLINK-21081) Re-compute tasks to trigger when
tasks get triggered before finished
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)