drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amansi...@apache.org
Subject [5/7] drill git commit: DRILL-5349: Fix TestParquetWriter unit tests when synchronous parquet reader is used.
Date Mon, 20 Mar 2017 15:56:58 GMT
DRILL-5349: Fix TestParquetWriter unit tests when synchronous parquet reader is used.

close apache/drill#780


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

Branch: refs/heads/master
Commit: 1766ffc4960e8f7c1efc981a9302688a8c6cd427
Parents: 2f13c08
Author: Parth Chandra <pchandra@maprtech.com>
Authored: Fri Mar 10 14:38:30 2017 -0800
Committer: Aman Sinha <asinha@maprtech.com>
Committed: Mon Mar 20 08:11:30 2017 -0700

----------------------------------------------------------------------
 .../apache/drill/exec/store/parquet/columnreaders/PageReader.java | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/drill/blob/1766ffc4/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/PageReader.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/PageReader.java
b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/PageReader.java
index e11fd65..8a783c9 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/PageReader.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/PageReader.java
@@ -254,6 +254,9 @@ class PageReader {
           this.parentColumnReader.parentReader.hadoopPath,
           this.parentColumnReader.columnDescriptor.toString(), start, 0, 0, timeToRead);
       timer.reset();
+      if (pageHeader.getType() == PageType.DICTIONARY_PAGE) {
+        readDictionaryPage(pageHeader, parentColumnReader);
+      }
     } while (pageHeader.getType() == PageType.DICTIONARY_PAGE);
 
     int compressedSize = pageHeader.getCompressed_page_size();


Mime
View raw message