aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetReaderUtility.java
diff options
context:
space:
mode:
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.java5
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();
}
}