drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From par...@apache.org
Subject drill git commit: DRILL-2109: Fix for parquet dictionary page reading
Date Thu, 29 Jan 2015 22:33:38 GMT
Repository: drill
Updated Branches:
  refs/heads/master 54b5f80a5 -> 09f7fb202


DRILL-2109: Fix for parquet dictionary page reading


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

Branch: refs/heads/master
Commit: 09f7fb202dd01558db0e1dce5974aa3ae5029ca3
Parents: 54b5f80
Author: Jason Altekruse <altekrusejason@gmail.com>
Authored: Wed Jan 28 12:21:44 2015 -0800
Committer: Parth Chandra <pchandra@maprtech.com>
Committed: Thu Jan 29 14:30:39 2015 -0800

----------------------------------------------------------------------
 .../exec/store/parquet/columnreaders/VarLengthColumnReaders.java   | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/drill/blob/09f7fb20/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/VarLengthColumnReaders.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/VarLengthColumnReaders.java
b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/VarLengthColumnReaders.java
index 11bd29f..7464f30 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/VarLengthColumnReaders.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/VarLengthColumnReaders.java
@@ -181,6 +181,7 @@ public class VarLengthColumnReaders {
       }
 
       if (usingDictionary) {
+        currDictValToWrite = pageReader.dictionaryValueReader.readBytes();
         DrillBuf b = DrillBuf.wrapByteBuffer(currDictValToWrite.toByteBuffer());
         int st=0;
         int len=currDictValToWrite.length();
@@ -263,6 +264,7 @@ public class VarLengthColumnReaders {
       }
 
       if (usingDictionary) {
+        currDictValToWrite = pageReader.dictionaryValueReader.readBytes();
         DrillBuf b = DrillBuf.wrapByteBuffer(currDictValToWrite.toByteBuffer());
         int st=0;
         int len=currDictValToWrite.length();


Mime
View raw message