diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/MySQLDorisE2ECase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/MySQLDorisE2ECase.java index cbc7734f2..99e7a13ec 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/MySQLDorisE2ECase.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/MySQLDorisE2ECase.java @@ -63,7 +63,7 @@ */ public class MySQLDorisE2ECase extends DorisTestBase { protected static final Logger LOG = LoggerFactory.getLogger(MySQLDorisE2ECase.class); - private static final String DATABASE = "test_mysql"; + private static final String DATABASE = "test_e2e_mysql"; private static final String MYSQL_USER = "root"; private static final String MYSQL_PASSWD = "123456"; private static final String TABLE_1 = "tbl1";