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

Yun Gao updated FLINK-25383:
----------------------------
    Description: Currently all the tasks would wait for final checkpoint before 
exiting. However, if the checkpoint type is checkpoint and the task does not 
contains the 2pc operators, it could skip waiting for the checkpoint.

> Skip waiting for the final checkpoint if the task do not contains 2-pc 
> operators
> --------------------------------------------------------------------------------
>
>                 Key: FLINK-25383
>                 URL: https://issues.apache.org/jira/browse/FLINK-25383
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Checkpointing
>            Reporter: Yun Gao
>            Priority: Major
>
> Currently all the tasks would wait for final checkpoint before exiting. 
> However, if the checkpoint type is checkpoint and the task does not contains 
> the 2pc operators, it could skip waiting for the checkpoint.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to