github-forks
/
flink-cdc-connectors
mirror of https://github.com/ververica/flink-cdc-connectors.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[hotfix][cdc-common] Fix NoSuchMethodError of CollectionUtil.newHashMapWithExpectedSize

Browse Source 
This closes #2943
pull/2994/head
Kunni 1 year ago committed by GitHub
parent a24c5d1b24
commit 146ed9d0be
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File

4
flink-cdc-common/src/main/java/com/ververica/cdc/common/utils/InstantiationUtil.java
Unescape Escape View File

@ -19,7 +19,6 @@ package com.ververica.cdc.common.utils;
import org.apache.flink.api.common.typeutils.TypeSerializer; import org.apache.flink.api.common.typeutils.TypeSerializer;
import org.apache.flink.core.memory.DataInputViewStreamWrapper; import org.apache.flink.core.memory.DataInputViewStreamWrapper;
import org.apache.flink.core.memory.DataOutputViewStreamWrapper; import org.apache.flink.core.memory.DataOutputViewStreamWrapper;
import org.apache.flink.util.CollectionUtil;
import java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream; import java.io.ByteArrayOutputStream;
@ -112,8 +111,7 @@ public class InstantiationUtil {
// ------------------------------------------------ // ------------------------------------------------
private static final HashMap<String, Class<?>> primitiveClasses = private static final HashMap<String, Class<?>> primitiveClasses = new HashMap<>(9);
CollectionUtil.newHashMapWithExpectedSize(9);
static { static {
primitiveClasses.put("boolean", boolean.class); primitiveClasses.put("boolean", boolean.class);

Write Preview
Loading…
Cancel
Save