From 65631ddd9ba2446f6cb07921c3f1740bd43f63f9 Mon Sep 17 00:00:00 2001 From: Parth Chandra Date: Fri, 10 Mar 2017 14:38:30 -0800 Subject: [PATCH] DRILL-5349: Fix TestParquetWriter unit tests when synchronous parquet reader is used. --- .../drill/exec/store/parquet/columnreaders/PageReader.java | 3 +++ 1 file changed, 3 insertions(+) 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 e11fd65ac03..8a783c91e74 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 @@ protected void nextInternal() throws IOException{ 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();