You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/01/27 13:53:00 UTC

[jira] [Updated] (FLINK-23342) State ownership: compute shared state on recovery

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

Roman Khachatryan updated FLINK-23342:
--------------------------------------
        Parent:     (was: FLINK-21352)
    Issue Type: Technical Debt  (was: Sub-task)

> State ownership: compute shared state on recovery
> -------------------------------------------------
>
>                 Key: FLINK-23342
>                 URL: https://issues.apache.org/jira/browse/FLINK-23342
>             Project: Flink
>          Issue Type: Technical Debt
>          Components: Runtime / State Backends
>            Reporter: Roman Khachatryan
>            Assignee: Roman Khachatryan
>            Priority: Major
>              Labels: pull-request-available, stale-assigned
>             Fix For: 1.15.0
>
>
> # Introduce / refactor State object ID (consider StringBasedID, SharedStateRegistryKey, StateHandleID; consider merging them)
>  # Add methods to obtain all object ids from a state handle
>  # Upate StateAssignmentOperation to compute shared state as a last step
>  # Send to TM (inject into JMTaskRestore)
> See [https://docs.google.com/document/d/1NJJQ30P27BmUvD7oa4FChvkYxMEgjRPTVdO1dHLl_9I/edit#heading=h.uednun2snp4l] for more details
>  
> Code changes might look like this: [https://github.com/rkhachatryan/flink/commit/025813c68b71e9fc357d7417d4403141998ad5f9#diff-cc692216ebbbeda497a335d79a1e568bb5164d98a45bd8efba08b9c1e9742ebdR144] 



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