This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 455246b84e [flink] avoid using 'newHashMapWithExpectedSize' which is
internal in flink (#4713)
455246b84e is described below
commit 455246b84e2632fc62ab4d3cf3da86ad77db4753
Author: LsomeYeah <[email protected]>
AuthorDate: Mon Dec 16 13:41:38 2024 +0800
[flink] avoid using 'newHashMapWithExpectedSize' which is internal in flink
(#4713)
---
.../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 34f9d035d8..e21220b26d 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.DataOutputView;
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 @@ public class ChangelogCompactTaskSerializer
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));
}
