flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Holger Frydrych (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4709) InputStreamFSInputWrapper does not close wrapped stream
Date Thu, 29 Sep 2016 09:01:20 GMT
Holger Frydrych created FLINK-4709:

             Summary: 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.1.2, 1.0.3
            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