flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream
Date Wed, 05 Oct 2016 22:25:20 GMT

     [ https://issues.apache.org/jira/browse/FLINK-4709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Stephan Ewen resolved FLINK-4709.
---------------------------------
       Resolution: Fixed
    Fix Version/s: 1.2.0

Fixed via 28b37ef97d803855e884900d1a983813ea2ac99d

> 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
>             Fix For: 1.2.0
>
>
> 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)

Mime
View raw message