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> map, DataOutputView v private Map> deserializeMap(DataInputView view) throws IOException { final int size = view.readInt(); - final Map> map = - CollectionUtil.newHashMapWithExpectedSize(size); + final Map> map = new HashMap<>(size); for (int i = 0; i < size; i++) { map.put(view.readInt(), dataFileSerializer.deserializeList(view)); }