[ 
https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714845#comment-17714845
 ] 

Fan Hong commented on FLINK-31846:
----------------------------------

Hi, [~pnowojski] . Thank you for explaining. I am actually a novice when it 
comes to checkpoints.

If the final checkpoint cannot be cancelled, can we bring it forward to start 
upon completion of all tasks? It at least saves the time between the final 
checkpoint and the one before the final one.

 

Your suggestions are valuable and I will consider whether they can be applied 
to my work. In my cases, I use general codes to process bounded datasets of 
various sizes. Therefore, I am in search of a standardized checkpoint interval 
that can be uniformly applied to all jobs. Waiting for an extra checkpoint 
could be costly for certain bounded datasets.

 

> Support cancel final checkpoint when all tasks are finished
> -----------------------------------------------------------
>
>                 Key: FLINK-31846
>                 URL: https://issues.apache.org/jira/browse/FLINK-31846
>             Project: Flink
>          Issue Type: New Feature
>          Components: Runtime / Checkpointing
>    Affects Versions: 1.15.2
>            Reporter: Fan Hong
>            Priority: Major
>
> As stated in [1], all tasks will wait for the final checkpoint before 
> exiting. It also mentioned this mechanism will prolong the execution time.
> So, can we provide configurations to make tasks NOT wait for the final 
> checkpoint?
>  
>  [1]: 
> https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/checkpointing/#waiting-for-the-final-checkpoint-before-task-exit



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to