diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetFileWriter.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetFileWriter.java index e2df7af33f..3b4fdb08ee 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetFileWriter.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ParquetFileWriter.java @@ -1217,7 +1217,7 @@ private static void serializeColumnIndexes( BlockCipher.Encryptor columnIndexEncryptor = null; byte[] columnIndexAAD = null; if (null != fileEncryptor) { - InternalColumnEncryptionSetup columnEncryptionSetup = fileEncryptor.getColumnSetup(column.getPath(), false, cIndex); + InternalColumnEncryptionSetup columnEncryptionSetup = fileEncryptor.getColumnSetup(column.getPath(), true, cIndex); if (columnEncryptionSetup.isEncrypted()) { columnIndexEncryptor = columnEncryptionSetup.getMetaDataEncryptor(); columnIndexAAD = AesCipher.createModuleAAD(fileEncryptor.getFileAAD(), ModuleType.ColumnIndex, @@ -1257,7 +1257,7 @@ private static void serializeOffsetIndexes( BlockCipher.Encryptor offsetIndexEncryptor = null; byte[] offsetIndexAAD = null; if (null != fileEncryptor) { - InternalColumnEncryptionSetup columnEncryptionSetup = fileEncryptor.getColumnSetup(column.getPath(), false, cIndex); + InternalColumnEncryptionSetup columnEncryptionSetup = fileEncryptor.getColumnSetup(column.getPath(), true, cIndex); if (columnEncryptionSetup.isEncrypted()) { offsetIndexEncryptor = columnEncryptionSetup.getMetaDataEncryptor(); offsetIndexAAD = AesCipher.createModuleAAD(fileEncryptor.getFileAAD(), ModuleType.OffsetIndex, @@ -1296,7 +1296,7 @@ private static void serializeBloomFilters( byte[] bloomFilterHeaderAAD = null; byte[] bloomFilterBitsetAAD = null; if (null != fileEncryptor) { - InternalColumnEncryptionSetup columnEncryptionSetup = fileEncryptor.getColumnSetup(column.getPath(), false, cIndex); + InternalColumnEncryptionSetup columnEncryptionSetup = fileEncryptor.getColumnSetup(column.getPath(), true, cIndex); if (columnEncryptionSetup.isEncrypted()) { bloomFilterEncryptor = columnEncryptionSetup.getMetaDataEncryptor(); int columnOrdinal = columnEncryptionSetup.getOrdinal();