[fix] repair a snapshot-split bug:

resolved the conflict of org.apache.flink.cdc.connectors.mysql.source.utils.ObjectUtilsTest
apache · May 6, 2024 · 197e5bd · 197e5bd
1 parent 2c5e06e
commit 197e5bd
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/...cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/utils/ObjectUtilsTest.java b/...cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/utils/ObjectUtilsTest.java
@@ -17,11 +17,11 @@
 
 package org.apache.flink.cdc.connectors.mysql.source.utils;
 
-import com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils;
-import com.ververica.cdc.connectors.mysql.source.MySqlSourceTestBase;
-import com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig;
-import com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory;
-import com.ververica.cdc.connectors.mysql.testutils.UniqueDatabase;
+import org.apache.flink.cdc.connectors.mysql.debezium.DebeziumUtils;
+import org.apache.flink.cdc.connectors.mysql.source.MySqlSourceTestBase;
+import org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceConfig;
+import org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory;
+import org.apache.flink.cdc.connectors.mysql.testutils.UniqueDatabase;
 import io.debezium.connector.mysql.MySqlConnection;
 import io.debezium.relational.TableId;
 import org.junit.AfterClass;
@@ -66,8 +66,6 @@ public static void afterClass() throws Exception {
             mySqlConnection.close();
         }
     }
-/** Tests for {@link org.apache.flink.cdc.connectors.mysql.source.utils.ObjectUtils}. */
-public class ObjectUtilsTest {
 
     @Test
     public void testMinus() {