You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Holger Frydrych (JIRA)" <ji...@apache.org> on 2016/09/29 09:01:20 UTC
[jira] [Created] (FLINK-4709) InputStreamFSInputWrapper does not
close wrapped stream
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
(v6.3.4#6332)