You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2015/08/06 03:01:11 UTC

hive git commit: HIVE-11479 : LLAP: ORC-related refactoring changes broke something (Sergey Shelukhin)

Repository: hive
Updated Branches:
  refs/heads/llap c8ae1fbf1 -> b8902c9cb


HIVE-11479 : LLAP: ORC-related refactoring changes broke something (Sergey Shelukhin)


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

Branch: refs/heads/llap
Commit: b8902c9cb34ba89e9522fceb5d04eb0b2a19c5aa
Parents: c8ae1fb
Author: Sergey Shelukhin <se...@apache.org>
Authored: Wed Aug 5 18:00:59 2015 -0700
Committer: Sergey Shelukhin <se...@apache.org>
Committed: Wed Aug 5 18:00:59 2015 -0700

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


http://git-wip-us.apache.org/repos/asf/hive/blob/b8902c9c/ql/src/java/org/apache/hadoop/hive/ql/io/orc/EncodedReaderImpl.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/EncodedReaderImpl.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/EncodedReaderImpl.java
index e9c32ed..e79973a 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/EncodedReaderImpl.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/EncodedReaderImpl.java
@@ -374,8 +374,9 @@ public class EncodedReaderImpl implements EncodedReader {
     }
 
     if (!result.value) {
-      if (isDataReaderOpen) {
+      if (!isDataReaderOpen) {
         this.dataReader.open();
+        isDataReaderOpen = true;
       }
       dataReader.readFileData(toRead.next, stripeOffset, cache.getAllocator().isDirectAlloc());
     }