diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageReadStore.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageReadStore.java index 9bbd44b3ea..8948f3a9be 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageReadStore.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageReadStore.java @@ -167,10 +167,12 @@ public DataPage readPage() { public DataPage visit(DataPageV1 dataPageV1) { try { BytesInput bytes = dataPageV1.getBytes(); - ByteBuffer byteBuffer = bytes.toByteBuffer(); long compressedSize = bytes.size(); - if (null != blockDecryptor) { + ByteBuffer byteBuffer; + if (blockDecryptor == null) { + byteBuffer = bytes.toByteBuffer(); + } else { byte[] decrypted = blockDecryptor.decrypt(bytes.toByteArray(), dataPageAAD); compressedSize = decrypted.length; byteBuffer = ByteBuffer.allocateDirect((int) compressedSize);