You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by pa...@apache.org on 2015/01/29 23:33:38 UTC
drill git commit: DRILL-2109: Fix for parquet dictionary page reading
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 <al...@gmail.com>
Authored: Wed Jan 28 12:21:44 2015 -0800
Committer: Parth Chandra <pc...@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();