Sihua Zhou created FLINK-8777:
---------------------------------
Summary: improve resource release when recovery from failover
Key: FLINK-8777
URL: https://issues.apache.org/jira/browse/FLINK-8777
Project: Flink
Issue Type: Improvement
Components: State Backends, Checkpointing
Affects Versions: 1.5.0
Reporter: Sihua Zhou
Assignee: Sihua Zhou
Fix For: 1.5.0
When recovery from failed, {{TaskLocalStateStoreImpl.retrieveLocalState()}}
will be invoked, we can release all entry from
{{storedTaskStateByCheckpointID}} that does not satisfy {{entry.checkpointID
== checkpointID}}, this can prevent the resource leak when job loop in {{local
checkpoint completed => failed => local checkpoint completed => failed ...}}.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
