[jira] [Issue Comment Deleted] (FLINK-5347) Unclosed stream in OperatorBackendSerializationProxy#write()

["Stefan Richter (JIRA)" <ji...@apache.org>]

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

Stefan Richter updated FLINK-5347:
----------------------------------
    Comment: was deleted

(was: The stream is not opened in the method and therefore should also not be closed here. Consecutive writes to the stream should be possible and the caller is responsible for closing.)

> Unclosed stream in OperatorBackendSerializationProxy#write()
> ------------------------------------------------------------
>
>                 Key: FLINK-5347
>                 URL: https://issues.apache.org/jira/browse/FLINK-5347
>             Project: Flink
>          Issue Type: Bug
>            Reporter: Ted Yu
>            Priority: Minor
>
> {code}
>     public void write(DataOutputView out) throws IOException {
>       out.writeUTF(getName());
>       DataOutputViewStream dos = new DataOutputViewStream(out);
>       InstantiationUtil.serializeObject(dos, getStateSerializer());
>     }
> {code}
> dos should be closed upon return from the method.



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