[
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)
