This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 98400bbb3f171ae851e9f53e0af3cd77bf65e948 Author: Stephan Ewen <[email protected]> AuthorDate: Mon Nov 9 19:53:15 2020 +0100 [hotfix] Close File FormatReaders also when the source reader is closed before end of split. --- .../apache/flink/connector/file/src/impl/FileSourceSplitReader.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/impl/FileSourceSplitReader.java b/flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/impl/FileSourceSplitReader.java index 00f6a66..c928c5b 100644 --- a/flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/impl/FileSourceSplitReader.java +++ b/flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/src/impl/FileSourceSplitReader.java @@ -86,7 +86,11 @@ final class FileSourceSplitReader<T, SplitT extends FileSourceSplit> implements public void wakeUp() {} @Override - public void close() throws Exception {} + public void close() throws Exception { + if (currentReader != null) { + currentReader.close(); + } + } private void checkSplitOrStartNext() throws IOException { if (currentReader != null) {
