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 20efe47573..f51d9092e4 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 @@ -848,7 +848,7 @@ public void appendRowGroup(SeekableInputStream from, BlockMetaData rowGroup, // copy the data for all chunks long start = -1; long length = 0; - long blockCompressedSize = 0; + long blockUncompressedSize = 0L; for (int i = 0; i < columnsInOrder.size(); i += 1) { ColumnChunkMetaData chunk = columnsInOrder.get(i); @@ -889,10 +889,10 @@ public void appendRowGroup(SeekableInputStream from, BlockMetaData rowGroup, chunk.getTotalSize(), chunk.getTotalUncompressedSize())); - blockCompressedSize += chunk.getTotalSize(); + blockUncompressedSize += chunk.getTotalUncompressedSize(); } - currentBlock.setTotalByteSize(blockCompressedSize); + currentBlock.setTotalByteSize(blockUncompressedSize); endBlock(); }