PARQUET-2183: Fix statistics issue of Column Encryptor

cloudaware · Sep 3, 2022 · 1f9c3f7 · 1f9c3f7
1 parent 6add627
commit 1f9c3f7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/util/ColumnEncryptor.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/util/ColumnEncryptor.java
@@ -204,7 +204,7 @@ private void processChunk(ColumnDescriptor descriptor, ColumnChunkMetaData chunk
     reader.setStreamPosition(chunk.getStartingPos());
     writer.startColumn(descriptor, chunk.getValueCount(), chunk.getCodec());
     processPages(reader, chunk, writer, createdBy, blockId, columnId, encryptPaths.contains(chunk.getPath()));
-    writer.endColumn();
+    writer.endColumn(chunk.getStatistics());
   }
 
   private void processPages(TransParquetFileReader reader, ColumnChunkMetaData chunk, ParquetFileWriter writer,