From 197e5bdddd29c857ee482a22cd6d8c16be06f779 Mon Sep 17 00:00:00 2001 From: AidenPerce Date: Mon, 6 May 2024 11:00:19 +0800 Subject: [PATCH] [fix] repair a snapshot-split bug: resolved the conflict of org.apache.flink.cdc.connectors.mysql.source.utils.ObjectUtilsTest --- .../mysql/source/utils/ObjectUtilsTest.java | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/utils/ObjectUtilsTest.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/utils/ObjectUtilsTest.java index 53600fa2d70..dc6839006a3 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/utils/ObjectUtilsTest.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-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() {