[
https://issues.apache.org/jira/browse/FLINK-21081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-21081:
----------------------------
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](https://issues.apache.org/jira/browse/FLINK-21246)
was: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.
> 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
> Components: API / DataStream, Runtime / Checkpointing
> Reporter: Yun Gao
> Priority: Major
> Labels: pull-request-available
>
> 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](https://issues.apache.org/jira/browse/FLINK-21246)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
