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

Yun Gao updated FLINK-25105:
----------------------------
    Release Note: 
In 1.15 we enabled the support of checkpoints after part of tasks finished by 
default, and make tasks waiting for the final checkpoint before exit to ensures 
all data get committed. 

However, it needs to note that make tasks waiting for one more checkpoint 
before exit would also block the tasks until the next checkpoint get triggered. 
If the checkpoint interval is long, the tasks' execution time would also be 
extended largely. In the worst case if the checkpoint interval is 
Long.MAX_VALUE, the tasks would be in fact blocked forever. 

More information about this feature and how to disable it could be found in 
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/checkpointing/#checkpointing-with-parts-of-the-graph-finished-beta.
 

  was:
In 1.15 we enabled the support of checkpoints after part of tasks finished by 
default, and make tasks waiting for the final checkpoint before exit to ensures 
all data get committed. 

However, it needs note that make tasks waiting for one more checkpoint before 
exit would also block the tasks until the next checkpoint get triggered. If the 
checkpoint interval is long, the tasks' execution time would also be extended 
largely. In the worst case if the checkpoint interval is Long.MAX_VALUE, the 
tasks would be in fact blocked forever. 

More information about this feature and how to disable it could be found in 
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/fault-tolerance/checkpointing/#checkpointing-with-parts-of-the-graph-finished-beta.
 


> Enables final checkpoint by default
> -----------------------------------
>
>                 Key: FLINK-25105
>                 URL: https://issues.apache.org/jira/browse/FLINK-25105
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Checkpointing
>    Affects Versions: 1.15.0
>            Reporter: Yun Gao
>            Assignee: Yun Gao
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.15.0
>
>
> We would fix all the conflict tests and enable the feature by default in this 
> version.



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

Reply via email to