Details
-
Bug
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
None
-
None
-
None
-
None
Description
HashMap<String, RocksDBStateBackend.FinalFullyAsyncSnapshot> namedStates =
InstantiationUtil.deserializeObject(restoreState.iterator().next().openInputStream(), userCodeClassLoader);
The InputStream returned by openInputStream() should be closed upon return from the method.
Similar problem exists in HeapKeyedStateBackend#restoreOldSavepointKeyedState