[
https://issues.apache.org/jira/browse/FLINK-21504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-21504.
------------------------------
Resolution: Fixed
merged in master: def3855690f8a5ac24a889dc4ed5909d4f9b31aa
> State ownership: notify TMs about checkpoint subsumption
> --------------------------------------------------------
>
> Key: FLINK-21504
> URL: https://issues.apache.org/jira/browse/FLINK-21504
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Checkpointing
> Reporter: Roman Khachatryan
> Assignee: Yun Tang
> Priority: Major
> Labels: auto-unassigned, pull-request-available
> Fix For: 1.15.0
>
>
> Goal: enable TMs to discard state after subsumption (FLINK-23139).
> Proposed solution: include earliest non-subsumed checkpoint ID into
> checkpoint confirmation notification.
> Code-wise, it would require passing the checkpoint ID through many existing
> CheckpointListener implementations (e.g. Task). CheckpointListener is a
> public interface and should not be concerned with retained checkpoints
> (runtime detail). So it's better to remove "implements" from such classes and
> either call methods directly or introduce a new (runtime) interface if
> necessary.
>
> See [state ownership design
> doc|https://docs.google.com/document/d/1NJJQ30P27BmUvD7oa4FChvkYxMEgjRPTVdO1dHLl_9I/edit?usp=sharing],
> in particular [subsumption
> notifications|https://docs.google.com/document/d/1NJJQ30P27BmUvD7oa4FChvkYxMEgjRPTVdO1dHLl_9I/edit#heading=h.auqo5xe66sg5]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
