This is an automated email from the ASF dual-hosted git repository. amansinha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/drill.git
commit 0543dbb356c669132c8ac75a99b318661bdcf664 Author: Bohdan Kazydub <[email protected]> AuthorDate: Thu Dec 6 15:03:25 2018 +0200 DRILL-6874: Close input stream after AsyncPageReaderTask is completed close apache/drill#1565 --- .../drill/exec/store/parquet/columnreaders/AsyncPageReader.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/AsyncPageReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/AsyncPageReader.java index e429fb6..8b5c926 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/AsyncPageReader.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/AsyncPageReader.java @@ -417,6 +417,13 @@ class AsyncPageReader extends PageReader { if (totalValuesRead >= totalValuesCount) { try { queue.put(ReadStatus.EMPTY); + // Some InputStreams (like S3ObjectInputStream) should be closed + // as soon as possible to make the connection reusable. + try { + parent.inputStream.close(); + } catch (IOException e) { + logger.trace(String.format("[%s]: Failure while closing InputStream", name), e); + } } catch (InterruptedException e) { Thread.currentThread().interrupt(); // Do nothing.
