diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/format/converter/ParquetMetadataConverter.java b/parquet-hadoop/src/main/java/org/apache/parquet/format/converter/ParquetMetadataConverter.java index e752b4ceea..bed26421f9 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/format/converter/ParquetMetadataConverter.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/format/converter/ParquetMetadataConverter.java @@ -534,8 +534,9 @@ private void addRowGroup( int columnOrdinal = -1; ByteArrayOutputStream tempOutStream = null; for (ColumnChunkMetaData columnMetaData : columns) { - ColumnChunk columnChunk = - new ColumnChunk(columnMetaData.getFirstDataPageOffset()); // verify this is the right offset + // There is no ColumnMetaData written after the chunk data, so set the ColumnChunk + // file_offset to 0 + ColumnChunk columnChunk = new ColumnChunk(0); columnChunk.file_path = block.getPath(); // they are in the same file for now InternalColumnEncryptionSetup columnSetup = null; boolean writeCryptoMetadata = false;