[jira] [Commented] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream

["Stephan Ewen (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15532237#comment-15532237 ] 

Stephan Ewen commented on FLINK-4709:
-------------------------------------

Good catch. Do you want to open a pull request for that?

> InputStreamFSInputWrapper does not close wrapped stream
> -------------------------------------------------------
>
>                 Key: FLINK-4709
>                 URL: https://issues.apache.org/jira/browse/FLINK-4709
>             Project: Flink
>          Issue Type: Bug
>          Components: Core
>    Affects Versions: 1.0.3, 1.1.2
>            Reporter: Holger Frydrych
>
> In FileInputFormat::decorateInputStream (flink.api.common.io), if the inputStream gets wrapped by an InputStreamFSInputWrapper, it will never get closed. FileInputFormat does call close() on its stream, but the wrapper does not implement close() to forward this call to the wrapped stream. This leads to a resource leak which can eventually exhaust the maximum number of open file handles allowed if processing a lot of input files.



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