[drill] branch master updated: DRILL-7937: INTERNAL_ERROR when querying Parquet File with decimals

[luoc]

This is an automated email from the ASF dual-hosted git repository.

luoc pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git


The following commit(s) were added to refs/heads/master by this push:
     new f86a7cb  DRILL-7937: INTERNAL_ERROR when querying Parquet File with 
decimals
f86a7cb is described below

commit f86a7cb1fc696c97852cff66f2de260c9001ecb4
Author: Volodymyr Vysotskyi <vvo...@gmail.com>
AuthorDate: Tue Jun 1 21:38:34 2021 +0300

    DRILL-7937: INTERNAL_ERROR when querying Parquet File with decimals
---
 .../store/parquet/columnreaders/NullableFixedByteAlignedReaders.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableFixedByteAlignedReaders.java
 
b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableFixedByteAlignedReaders.java
index 9849b7d..389962f 100644
--- 
a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableFixedByteAlignedReaders.java
+++ 
b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/columnreaders/NullableFixedByteAlignedReaders.java
@@ -321,6 +321,8 @@ public class NullableFixedByteAlignedReaders {
         case FIXED_LEN_BYTE_ARRAY:
         case BINARY:
           if (usingDictionary) {
+            recordsReadInThisIteration = Math.min(pageReader.currentPageCount
+                - pageReader.valuesRead, recordsToReadInThisPass - 
valuesReadInCurrentPass);
             NullableVarDecimalVector.Mutator mutator = valueVec.getMutator();
             for (int i = 0; i < recordsReadInThisIteration; i++) {
               Binary currDictValToWrite = 
pageReader.dictionaryValueReader.readBytes();