[cdc-common][hotfix] Remove useless flink imports (apache#2803)

This closes apache#2803.
ChaomingZhangCN · Jan 3, 2025 · 12ed1ba · 12ed1ba
1 parent 2cd630a
commit 12ed1ba
Show file tree

Hide file tree

Showing 8 changed files with 18 additions and 17 deletions.
diff --git a/flink-cdc-common/src/main/java/com/ververica/cdc/common/data/binary/BinaryRecordData.java b/flink-cdc-common/src/main/java/com/ververica/cdc/common/data/binary/BinaryRecordData.java
@@ -37,7 +37,7 @@
 import java.nio.ByteOrder;
 
 import static com.ververica.cdc.common.types.DataTypeRoot.DECIMAL;
-import static org.apache.flink.util.Preconditions.checkArgument;
+import static com.ververica.cdc.common.utils.Preconditions.checkArgument;
 
 /**
  * An implementation of {@link RecordData} which is backed by {@link MemorySegment} instead of

diff --git a/flink-cdc-common/src/main/java/com/ververica/cdc/common/factories/FactoryHelper.java b/flink-cdc-common/src/main/java/com/ververica/cdc/common/factories/FactoryHelper.java
@@ -16,8 +16,7 @@
 
 package com.ververica.cdc.common.factories;
 
-import org.apache.flink.annotation.PublicEvolving;
-
+import com.ververica.cdc.common.annotation.PublicEvolving;
 import com.ververica.cdc.common.configuration.Configuration;
 
 import java.util.Map;

diff --git a/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/EnumSerializer.java b/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/EnumSerializer.java
@@ -16,14 +16,15 @@
 
 package com.ververica.cdc.runtime.serializer;
 
-import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility;
 import org.apache.flink.api.common.typeutils.TypeSerializerSnapshot;
 import org.apache.flink.core.memory.DataInputView;
 import org.apache.flink.core.memory.DataOutputView;
 import org.apache.flink.util.InstantiationUtil;
 
+import com.ververica.cdc.common.annotation.VisibleForTesting;
+
 import java.io.IOException;
 import java.io.ObjectInputStream;
 import java.lang.reflect.Array;
@@ -33,9 +34,9 @@
 import java.util.Map;
 import java.util.Set;
 
-import static org.apache.flink.util.Preconditions.checkArgument;
-import static org.apache.flink.util.Preconditions.checkNotNull;
-import static org.apache.flink.util.Preconditions.checkState;
+import static com.ververica.cdc.common.utils.Preconditions.checkArgument;
+import static com.ververica.cdc.common.utils.Preconditions.checkNotNull;
+import static com.ververica.cdc.common.utils.Preconditions.checkState;
 
 /** {@link TypeSerializer} for Java enums. */
 public final class EnumSerializer<T extends Enum<T>> extends TypeSerializer<T> {

diff --git a/...-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/LinkedListSerializer.java b/...-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/LinkedListSerializer.java
@@ -16,18 +16,19 @@
 
 package com.ververica.cdc.runtime.serializer;
 
-import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.api.common.typeutils.TypeSerializerSnapshot;
 import org.apache.flink.api.java.typeutils.runtime.MaskUtils;
 import org.apache.flink.core.memory.DataInputView;
 import org.apache.flink.core.memory.DataOutputView;
 
+import com.ververica.cdc.common.annotation.Internal;
+
 import java.io.IOException;
 import java.util.LinkedList;
 
-import static org.apache.flink.util.Preconditions.checkNotNull;
+import static com.ververica.cdc.common.utils.Preconditions.checkNotNull;
 
 /**
  * A serializer for {@link LinkedList}. The serializer relies on an element serializer for the

diff --git a/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/ListSerializer.java b/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/ListSerializer.java
@@ -26,7 +26,7 @@
 import java.util.ArrayList;
 import java.util.List;
 
-import static org.apache.flink.util.Preconditions.checkNotNull;
+import static com.ververica.cdc.common.utils.Preconditions.checkNotNull;
 
 /**
  * A serializer for {@link List Lists}. The serializer relies on an element serializer for the

diff --git a/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/MapSerializer.java b/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/MapSerializer.java
@@ -21,12 +21,13 @@
 import org.apache.flink.api.common.typeutils.TypeSerializerSnapshot;
 import org.apache.flink.core.memory.DataInputView;
 import org.apache.flink.core.memory.DataOutputView;
-import org.apache.flink.util.Preconditions;
 
 import java.io.IOException;
 import java.util.HashMap;
 import java.util.Map;
 
+import static com.ververica.cdc.common.utils.Preconditions.checkNotNull;
+
 /**
  * A serializer for {@link Map}. The serializer relies on a key serializer and a value serializer
  * for the serialization of the map's key-value pairs.
@@ -56,10 +57,9 @@ public final class MapSerializer<K, V> extends TypeSerializer<Map<K, V>> {
      * @param valueSerializer The serializer for the values in the map
      */
     public MapSerializer(TypeSerializer<K> keySerializer, TypeSerializer<V> valueSerializer) {
-        this.keySerializer =
-                Preconditions.checkNotNull(keySerializer, "The key serializer cannot be null");
+        this.keySerializer = checkNotNull(keySerializer, "The key serializer cannot be null");
         this.valueSerializer =
-                Preconditions.checkNotNull(valueSerializer, "The value serializer cannot be null.");
+                checkNotNull(valueSerializer, "The value serializer cannot be null.");
     }
 
     // ------------------------------------------------------------------------

diff --git a/...src/main/java/com/ververica/cdc/runtime/serializer/NestedSerializersSnapshotDelegate.java b/...src/main/java/com/ververica/cdc/runtime/serializer/NestedSerializersSnapshotDelegate.java
@@ -27,8 +27,8 @@
 import java.io.IOException;
 import java.util.Arrays;
 
-import static org.apache.flink.util.Preconditions.checkArgument;
-import static org.apache.flink.util.Preconditions.checkNotNull;
+import static com.ververica.cdc.common.utils.Preconditions.checkArgument;
+import static com.ververica.cdc.common.utils.Preconditions.checkNotNull;
 
 /**
  * A NestedSerializersSnapshotDelegate represents the snapshots of multiple serializers that are

diff --git a/...-runtime/src/main/java/com/ververica/cdc/runtime/serializer/data/ArrayDataSerializer.java b/...-runtime/src/main/java/com/ververica/cdc/runtime/serializer/data/ArrayDataSerializer.java
@@ -16,7 +16,6 @@
 
 package com.ververica.cdc.runtime.serializer.data;
 
-import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility;
 import org.apache.flink.api.common.typeutils.TypeSerializerSnapshot;
@@ -25,6 +24,7 @@
 import org.apache.flink.core.memory.DataInputView;
 import org.apache.flink.core.memory.DataOutputView;
 
+import com.ververica.cdc.common.annotation.VisibleForTesting;
 import com.ververica.cdc.common.data.ArrayData;
 import com.ververica.cdc.common.data.GenericArrayData;
 import com.ververica.cdc.common.types.DataType;