[ https://issues.apache.org/jira/browse/FLINK-4278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431697#comment-15431697 ]
ASF GitHub Bot commented on FLINK-4278: --------------------------------------- Github user nssalian commented on the issue: https://github.com/apache/flink/pull/2403 Hi @rmetzger, @tedyu do you have some time to help review this? I am not sure if the failures are related. > Unclosed FSDataOutputStream in multiple files in the project > ------------------------------------------------------------ > > Key: FLINK-4278 > URL: https://issues.apache.org/jira/browse/FLINK-4278 > Project: Flink > Issue Type: Bug > Affects Versions: 1.0.3 > Reporter: Neelesh Srinivas Salian > Assignee: Neelesh Srinivas Salian > > After FLINK-4259, I did a check and found that the following files don't have > the closing of the FSDataOutputStream. > The following are the files and the corresponding methods missing the close() > 1) FSDataOutputStream.java adding a close method in the abstract class > 2) FSStateBackend flush() and write() - closing the FSDataOutputStream > 3) StringWriter.java write() > 4) FileSystemStateStore putState() - closing the FSDataOutputStream > 5) HadoopDataOutputStream.java not too sure if this needs closing. > 6) FileSystemStateStorageHelper.java store() need closing for both outStream > and the ObjectOutputStream > The options to think would be to either close or use IOUtils.closeQuietly() > Any thoughts? -- This message was sent by Atlassian JIRA (v6.3.4#6332)