flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4278) Unclosed FSDataOutputStream in multiple files in the project
Date Mon, 22 Aug 2016 22:11:20 GMT

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

    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
> The options to think would be to either close or use  IOUtils.closeQuietly() 
> Any thoughts?

This message was sent by Atlassian JIRA

View raw message