[
https://issues.apache.org/jira/browse/FLINK-23137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-23137:
--------------------------------------
Description:
Inject shared state IDs computed in StateAssignmentOperation (FLINK-23342) into
the SharedStateRegistry and CheckpointsCleaner and ignore other states. Should
only affect changelog states (both materialized and non-materialized).
Injection into SharedStateRegistry is done in FLINK-23342 (or can be done in
this ticket).
Should take "changelog.enabled" and it's possible changes into account.
*Placeholder state handles* should still be replaced for both private and
shared state eventually - either as part of this or of a new ticket (see also
FLINK-23461).
See
[https://docs.google.com/document/d/1NJJQ30P27BmUvD7oa4FChvkYxMEgjRPTVdO1dHLl_9I/edit#heading=h.uednun2snp4l]
for more details
was:
Inject shared state IDs computed in StateAssignmentOperation (FLINK-23342) into
the SharedStateRegistry and CheckpointsCleaner and ignore other states. Should
only affect changelog states (both materialized and non-materialized).
Injection into SharedStateRegistry is done in FLINK-23342 (or can be done in
this ticket).
Should take "changelog.enabled" and it's possible changes into account.
*Placeholder state handles* should still be replaced for both private and
shared state eventually - either as part of this or of a new ticket.
See
[https://docs.google.com/document/d/1NJJQ30P27BmUvD7oa4FChvkYxMEgjRPTVdO1dHLl_9I/edit#heading=h.uednun2snp4l]
for more details
> State ownership: prevent private state deletion on JM
> -----------------------------------------------------
>
> Key: FLINK-23137
> URL: https://issues.apache.org/jira/browse/FLINK-23137
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / State Backends
> Reporter: Roman Khachatryan
> Assignee: Zakelly Lan
> Priority: Major
> Fix For: 1.14.0
>
>
> Inject shared state IDs computed in StateAssignmentOperation (FLINK-23342)
> into the SharedStateRegistry and CheckpointsCleaner and ignore other states.
> Should only affect changelog states (both materialized and non-materialized).
> Injection into SharedStateRegistry is done in FLINK-23342 (or can be done in
> this ticket).
> Should take "changelog.enabled" and it's possible changes into account.
> *Placeholder state handles* should still be replaced for both private and
> shared state eventually - either as part of this or of a new ticket (see also
> FLINK-23461).
>
> See
> [https://docs.google.com/document/d/1NJJQ30P27BmUvD7oa4FChvkYxMEgjRPTVdO1dHLl_9I/edit#heading=h.uednun2snp4l]
> for more details
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
