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-4709) InputStreamFSInputWrapper does not close wrapped stream
Date Mon, 03 Oct 2016 15:19:20 GMT

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

ASF GitHub Bot commented on FLINK-4709:

GitHub user fholger opened a pull request:


    [FLINK-4709] Fix resource leak in InputStreamFSInputWrapper

    InputStreamFSInputWrapper is a wrapper around an arbitrary Java InputStream. As such,
it needs to reimplement the close() function and forward it to the wrapped stream, otherwise
there is a potential resource leak. This PR forwards the close() call to the underlying stream.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/fholger/flink flink-4709

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2581
commit 8ac14e34f87bcc318e9a57b8385fc419f3443345
Author: Holger Frydrych <holger.frydrych@tngtech.com>
Date:   2016-10-03T12:34:19Z

    [FLINK-4709] Fix resource leak in InputStreamFSInputWrapper


> 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

View raw message