From 146ed9d0bea5446040a92d5bd51aef16a4c19f7b Mon Sep 17 00:00:00 2001 From: Kunni Date: Thu, 11 Jan 2024 15:47:32 +0800 Subject: [PATCH] [hotfix][cdc-common] Fix NoSuchMethodError of CollectionUtil.newHashMapWithExpectedSize This closes #2943 --- .../com/ververica/cdc/common/utils/InstantiationUtil.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/flink-cdc-common/src/main/java/com/ververica/cdc/common/utils/InstantiationUtil.java b/flink-cdc-common/src/main/java/com/ververica/cdc/common/utils/InstantiationUtil.java index fbed9409b..34a07467d 100644 --- a/flink-cdc-common/src/main/java/com/ververica/cdc/common/utils/InstantiationUtil.java +++ b/flink-cdc-common/src/main/java/com/ververica/cdc/common/utils/InstantiationUtil.java @@ -19,7 +19,6 @@ package com.ververica.cdc.common.utils; import org.apache.flink.api.common.typeutils.TypeSerializer; import org.apache.flink.core.memory.DataInputViewStreamWrapper; import org.apache.flink.core.memory.DataOutputViewStreamWrapper; -import org.apache.flink.util.CollectionUtil; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; @@ -112,8 +111,7 @@ public class InstantiationUtil { // ------------------------------------------------ - private static final HashMap> primitiveClasses = - CollectionUtil.newHashMapWithExpectedSize(9); + private static final HashMap> primitiveClasses = new HashMap<>(9); static { primitiveClasses.put("boolean", boolean.class);