From 728c1cbf97ef89d1041218240bb90b702911e51d Mon Sep 17 00:00:00 2001 From: ggershinsky Date: Tue, 9 May 2023 10:17:40 +0300 Subject: [PATCH] PARQUET-2297: Skip delta problem check --- .../java/org/apache/parquet/hadoop/ParquetRecordReader.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetRecordReader.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetRecordReader.java index e46ccdd156..b009810206 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetRecordReader.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetRecordReader.java @@ -173,7 +173,10 @@ private void initializeInternalReader(ParquetInputSplit split, Configuration con } } - if (!reader.getRowGroups().isEmpty()) { + if (!reader.getRowGroups().isEmpty() && + // Encrypted files (parquet-mr 1.12+) can't have the delta encoding problem (resolved in parquet-mr 1.8) + reader.getFileMetaData().getEncryptionType() != FileMetaData.EncryptionType.ENCRYPTED_FOOTER && + reader.getFileMetaData().getEncryptionType() != FileMetaData.EncryptionType.PLAINTEXT_FOOTER) { checkDeltaByteArrayProblem( reader.getFooter().getFileMetaData(), configuration, reader.getRowGroups().get(0));