[
https://issues.apache.org/jira/browse/FLINK-25105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski 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's worth noting that this change forces tasks to wait for one more
checkpoint before exiting. In other words, this change will block the tasks
until the next checkpoint get triggered and completed. 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 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.
> 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)
