fix ParquetRewriter constructor

MaxNevermind · Aug 7, 2024 · ae9589d · ae9589d
1 parent d306336
commit ae9589d
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/ParquetRewriter.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/ParquetRewriter.java
@@ -176,9 +176,12 @@ public ParquetRewriter(
     this.writer = writer;
     this.outSchema = outSchema;
     this.newCodecName = codecName;
-    originalCreatedBy = originalCreatedBy == null ? meta.getFileMetaData().getCreatedBy() : originalCreatedBy;
-    extraMetaData = meta.getFileMetaData().getKeyValueMetaData();
-    extraMetaData.put(ORIGINAL_CREATED_BY_KEY, originalCreatedBy);
+    extraMetaData = new HashMap<>(meta.getFileMetaData().getKeyValueMetaData());
+    extraMetaData.put(
+        ORIGINAL_CREATED_BY_KEY,
+        originalCreatedBy != null
+            ? originalCreatedBy
+            : meta.getFileMetaData().getCreatedBy());
     if (maskColumns != null && maskMode != null) {
       this.maskColumns = new HashMap<>();
       for (String col : maskColumns) {