Repository: hive Updated Branches: refs/heads/master 9925eb108 -> b101af1d0
HIVE-21005: LLAP: Reading more stripes per-split leaks ZlibCodecs (Nita Dembla, reviewed by Gopal V) Signed-off-by: Gopal V <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/b101af1d Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/b101af1d Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/b101af1d Branch: refs/heads/master Commit: b101af1d0563fe2bbe41f5e9f38ea575e1e3237c Parents: 9925eb1 Author: Nita Dembla <[email protected]> Authored: Tue Dec 11 10:34:43 2018 -0800 Committer: Gopal V <[email protected]> Committed: Tue Dec 11 10:34:43 2018 -0800 ---------------------------------------------------------------------- .../hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/b101af1d/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java ---------------------------------------------------------------------- diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java b/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java index 74cee64..e6d8b7a 100644 --- a/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java +++ b/llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java @@ -434,6 +434,13 @@ public class OrcEncodedDataReader extends CallableWithNdc<Void> private void ensureDataReader() throws IOException { ensureOrcReader(); + if (stripeReader != null) { + try { + stripeReader.close(); + } catch (IOException ex) { + // Ignore. + } + } // Reader creation updates HDFS counters, don't do it here. DataWrapperForOrc dw = new DataWrapperForOrc(); stripeReader = orcReader.encodedReader(
