From d1930924791f918a7af9b017afbe3febfe10f006 Mon Sep 17 00:00:00 2001
From: LsomeYeah <lleiyeah.cat@outlook.com>
Date: Mon, 16 Dec 2024 12:15:42 +0800
Subject: [PATCH] [flink] avoid using 'newHashMapWithExpectedSize' which is
 internal in flink

---
 .../compact/changelog/ChangelogCompactTaskSerializer.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/ChangelogCompactTaskSerializer.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/ChangelogCompactTaskSerializer.java
index 34f9d035d8d2..e21220b26db5 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/ChangelogCompactTaskSerializer.java
+++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/compact/changelog/ChangelogCompactTaskSerializer.java
@@ -26,10 +26,10 @@
 import org.apache.paimon.io.DataOutputViewStreamWrapper;
 
 import org.apache.flink.core.io.SimpleVersionedSerializer;
-import org.apache.flink.util.CollectionUtil;
 
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -102,8 +102,7 @@ private void serializeMap(Map<Integer, List<DataFileMeta>> map, DataOutputView v
     private Map<Integer, List<DataFileMeta>> deserializeMap(DataInputView view) throws IOException {
         final int size = view.readInt();
 
-        final Map<Integer, List<DataFileMeta>> map =
-                CollectionUtil.newHashMapWithExpectedSize(size);
+        final Map<Integer, List<DataFileMeta>> map = new HashMap<>(size);
         for (int i = 0; i < size; i++) {
             map.put(view.readInt(), dataFileSerializer.deserializeList(view));
         }