diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageWriteStore.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageWriteStore.java index d9e6ea0990..fd1673673d 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageWriteStore.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageWriteStore.java @@ -217,7 +217,7 @@ public void writePage( } if (pageWriteChecksumEnabled) { crc.reset(); - crc.update(compressedBytes.toByteArray()); + crc.update(compressedBytes.toByteBuffer(releaser)); parquetMetadataConverter.writeDataPageV1Header( (int) uncompressedSize, (int) compressedSize, @@ -322,13 +322,13 @@ public void writePageV2( if (pageWriteChecksumEnabled) { crc.reset(); if (repetitionLevels.size() > 0) { - crc.update(repetitionLevels.toByteArray()); + crc.update(repetitionLevels.toByteBuffer(releaser)); } if (definitionLevels.size() > 0) { - crc.update(definitionLevels.toByteArray()); + crc.update(definitionLevels.toByteBuffer(releaser)); } if (compressedData.size() > 0) { - crc.update(compressedData.toByteArray()); + crc.update(compressedData.toByteBuffer(releaser)); } parquetMetadataConverter.writeDataPageV2Header( uncompressedSize,