diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseMySQLModeITCase.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseMySQLModeITCase.java index 61586545fe3..616ccd5e233 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseMySQLModeITCase.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseMySQLModeITCase.java @@ -31,8 +31,6 @@ import org.junit.Before; import org.junit.ClassRule; import org.junit.Test; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import org.testcontainers.containers.Network; import java.sql.Connection; @@ -47,8 +45,6 @@ /** Integration tests for OceanBase MySQL mode table source. */ public class OceanBaseMySQLModeITCase extends OceanBaseTestBase { - private static final Logger LOG = LoggerFactory.getLogger(OceanBaseMySQLModeITCase.class); - private final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); private final StreamTableEnvironment tEnv = diff --git a/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/OceanBaseE2eITCase.java b/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/OceanBaseE2eITCase.java index 996172f58d5..2cd2f88eb9f 100644 --- a/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/OceanBaseE2eITCase.java +++ b/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/src/test/java/org/apache/flink/cdc/connectors/tests/OceanBaseE2eITCase.java @@ -30,8 +30,6 @@ import org.junit.Before; import org.junit.ClassRule; import org.junit.Test; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; import java.nio.file.Path; import java.sql.Connection; @@ -47,8 +45,6 @@ /** End-to-end tests for oceanbase-cdc connector uber jar. */ public class OceanBaseE2eITCase extends FlinkContainerTestEnvironment { - private static final Logger LOG = LoggerFactory.getLogger(OceanBaseE2eITCase.class); - private static final String INTER_CONTAINER_OB_SERVER_ALIAS = "oceanbase"; private static final String INTER_CONTAINER_LOG_PROXY_ALIAS = "oblogproxy";