hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xu...@apache.org
Subject [29/55] [abbrv] hive git commit: HIVE-11688 : OrcRawRecordMerger does not close primary reader if not fully consumed (Sudheesh Katkam via Prasanth J)
Date Wed, 28 Oct 2015 12:11:22 GMT
HIVE-11688 : OrcRawRecordMerger does not close primary reader if not fully consumed (Sudheesh
Katkam via Prasanth J)

Signed-off-by: Ashutosh Chauhan <hashutosh@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/24ec6bed
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/24ec6bed
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/24ec6bed

Branch: refs/heads/spark
Commit: 24ec6bedaaf683ab7dd4fc28801f3283b5a1744f
Parents: a6da5d1
Author: Sudheesh Katkam <skatkam@maprtech.com>
Authored: Fri Aug 28 15:48:00 2015 -0800
Committer: Ashutosh Chauhan <hashutosh@apache.org>
Committed: Sat Oct 24 18:10:45 2015 -0700

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/24ec6bed/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java
index 58b85ef..fb5110d 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OrcRawRecordMerger.java
@@ -660,6 +660,9 @@ public class OrcRawRecordMerger implements AcidInputFormat.RawReader<OrcStruct>{
 
   @Override
   public void close() throws IOException {
+    if (primary != null) {
+      primary.recordReader.close();
+    }
     for(ReaderPair pair: readers.values()) {
       pair.recordReader.close();
     }


Mime
View raw message