Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.5.0
-
None
Description
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 ....
Attachments
Issue Links
- links to