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/12/18 02:56:41 UTC

drill git commit: DRILL-4205: Reset readStart every time a new page is read. This closes #306

Repository: drill
Updated Branches:
  refs/heads/master 2329c0569 -> abdfc6a96


DRILL-4205: Reset readStart every time a new page is read. This closes #306


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

Branch: refs/heads/master
Commit: abdfc6a969ca9801480dfed614abb8c6e056eb0a
Parents: 2329c05
Author: Parth Chandra <pa...@apache.org>
Authored: Wed Dec 16 15:25:26 2015 -0800
Committer: Parth Chandra <pa...@apache.org>
Committed: Thu Dec 17 17:54:44 2015 -0800

----------------------------------------------------------------------
 .../exec/store/parquet/columnreaders/NullableColumnReader.java      | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/drill/blob/abdfc6a9/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableColumnReader.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableColumnReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableColumnReader.java
index b8c81b4..4e52b70 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableColumnReader.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableColumnReader.java
@@ -73,6 +73,7 @@ abstract class NullableColumnReader<V extends ValueVector> extends ColumnReader<
         currentDefinitionLevel = -1;
         definitionLevelsRead = 0;
         recordsReadInThisIteration = 0;
+        readStartInBytes = 0;
       }
 
       nullRunLength = 0;