fix ut

JNSimba · Mar 1, 2024 · fea35a3 · fea35a3
1 parent 58618f9
commit fea35a3
Showing 1 changed file with 1 addition and 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
@@ -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