flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yun Gao (Jira)" <j...@apache.org>
Subject [jira] [Closed] (FLINK-21081) Re-compute tasks to trigger when tasks get triggered before finished
Date Tue, 09 Mar 2021 09:29:00 GMT

     [ https://issues.apache.org/jira/browse/FLINK-21081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Yun Gao closed FLINK-21081.
---------------------------
    Resolution: Later

> 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



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Mime
View raw message