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

Ted Yu updated FLINK-5283:
--------------------------
    Description: 
{code}
   HashMap<String, RocksDBStateBackend.FinalFullyAsyncSnapshot> namedStates =
        
InstantiationUtil.deserializeObject(restoreState.iterator().next().openInputStream(),
 userCodeClassLoader);
{code}
The InputStream returned by openInputStream() should be closed upon return from 
the method.

Similar problem exists in HeapKeyedStateBackend

  was:
{code}
      CheckpointStreamFactory.CheckpointStateOutputStream keyedStateOut =
          
checkpointStreamFactory.createCheckpointStateOutputStream(checkpointID, 0L);

      final long offset = keyedStateOut.getPos();
{code}
If getPos() throws exception, keyedStateOut would be left unclosed.


> InputStream should be closed in 
> RocksDBKeyedStateBackend#restoreOldSavepointKeyedState
> --------------------------------------------------------------------------------------
>
>                 Key: FLINK-5283
>                 URL: https://issues.apache.org/jira/browse/FLINK-5283
>             Project: Flink
>          Issue Type: Bug
>            Reporter: Ted Yu
>            Priority: Minor
>
> {code}
>    HashMap<String, RocksDBStateBackend.FinalFullyAsyncSnapshot> namedStates =
>         
> InstantiationUtil.deserializeObject(restoreState.iterator().next().openInputStream(),
>  userCodeClassLoader);
> {code}
> The InputStream returned by openInputStream() should be closed upon return 
> from the method.
> Similar problem exists in HeapKeyedStateBackend



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to