From fea35a3568723a674102472f1a46f2219e9db703 Mon Sep 17 00:00:00 2001 From: wudi <676366545@qq.com> Date: Fri, 1 Mar 2024 17:23:03 +0800 Subject: [PATCH] fix ut --- .../java/org/apache/doris/flink/tools/cdc/DatabaseSyncTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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