diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetReaderUtility.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetReaderUtility.java | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetReaderUtility.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetReaderUtility.java index 733915b61..14a222c37 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetReaderUtility.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetReaderUtility.java @@ -389,6 +389,11 @@ public class ParquetReaderUtility { minBytes = Base64.decodeBase64(minBytes); maxBytes = hasSingleValue ? minBytes : Base64.decodeBase64(maxBytes); } + } else if (minValue instanceof Binary && maxValue instanceof Binary) { + // for the case when cache file was auto-refreshed, values from parquet footers are used, + // so there is no need to convert values, but they should be set in ColumnMetadata + minBytes = ((Binary) minValue).getBytes(); + maxBytes = ((Binary) maxValue).getBytes(); } } |