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 bf75695b6be..a047fcc3e3e 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 @@ -445,8 +445,8 @@ public void clear(){ * @throws IOException An IO related condition */ void resetDefinitionLevelReader(int skipCount) throws IOException { - if (parentColumnReader.columnDescriptor.getMaxDefinitionLevel() != 0) { - throw new UnsupportedOperationException("Unsupoorted Operation"); + if (parentColumnReader.columnDescriptor.getMaxDefinitionLevel() > 1) { + throw new UnsupportedOperationException("Unsupported Operation"); } final Encoding dlEncoding = METADATA_CONVERTER.getEncoding(pageHeader.data_page_header.definition_level_encoding); diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/VarLenBulkPageReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/VarLenBulkPageReader.java index b6205c1ef3c..394f6ff8638 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/VarLenBulkPageReader.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/VarLenBulkPageReader.java @@ -72,6 +72,7 @@ final class VarLenBulkPageReader { this.pageInfo.numPageFieldsRead = pageInfoInput.numPageFieldsRead; this.pageInfo.definitionLevels = pageInfoInput.definitionLevels; this.pageInfo.dictionaryValueReader = pageInfoInput.dictionaryValueReader; + this.pageInfo.numPageValues = pageInfoInput.numPageValues; } this.columnPrecInfo = columnPrecInfoInput; @@ -94,6 +95,7 @@ final void set(PageDataInfo pageInfoInput) { pageInfo.numPageFieldsRead = pageInfoInput.numPageFieldsRead; pageInfo.definitionLevels = pageInfoInput.definitionLevels; pageInfo.dictionaryValueReader = pageInfoInput.dictionaryValueReader; + pageInfo.numPageValues = pageInfoInput.numPageValues; buffer.clear(); }