diff --git a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxSourceTCase.java b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxSourceITCase.java
similarity index 99%
rename from flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxSourceTCase.java
rename to flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxSourceITCase.java
index 754c75215cf..e628dbafaa5 100644
--- a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxSourceTCase.java
+++ b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxSourceITCase.java
@@ -69,8 +69,8 @@
  * we added fallback in {@link MySqlSchema} when parsing ddl failed and provided these cases to
  * test.
  */
-public class PolardbxSourceTCase extends AbstractTestBase {
-    private static final Logger LOG = LoggerFactory.getLogger(PolardbxSourceTCase.class);
+public class PolardbxSourceITCase extends AbstractTestBase {
+    private static final Logger LOG = LoggerFactory.getLogger(PolardbxSourceITCase.class);
     private static final Pattern COMMENT_PATTERN = Pattern.compile("^(.*)--.*$");
     private static final Integer PORT = 8527;
     private static final String HOST_NAME = "127.0.0.1";
@@ -131,7 +131,7 @@ private static Boolean checkConnection() {
     protected static void initializePolardbxTables(String databaseName)
             throws InterruptedException {
         final String ddlFile = String.format("ddl/%s.sql", databaseName);
-        final URL ddlTestFile = PolardbxSourceTCase.class.getClassLoader().getResource(ddlFile);
+        final URL ddlTestFile = PolardbxSourceITCase.class.getClassLoader().getResource(ddlFile);
         assertNotNull("Cannot locate " + ddlFile, ddlTestFile);
         // need to sleep 1s, make sure the jdbc connection can be created
         Thread.sleep(1000);