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)
