[
https://issues.apache.org/jira/browse/FLINK-5347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15752754#comment-15752754
]
Stefan Richter commented on FLINK-5347:
---------------------------------------
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)
