diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/DatabaseSyncTest.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/DatabaseSyncTest.java index 23dbff0b3..1e69c598f 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/DatabaseSyncTest.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/tools/cdc/DatabaseSyncTest.java @@ -62,7 +62,7 @@ public void getSyncTableListTest() throws Exception { config.setString("table-name", "tbl.*"); databaseSync.setConfig(config); String syncTableList = databaseSync.getSyncTableList(Arrays.asList("tbl_1", "tbl_2")); - assertEquals("db\\.tbl_1|db\\.tbl_2", syncTableList); + assertEquals("(db)\\.(tbl_1|tbl_2)", syncTableList); } @Test