[hotfix] Fix unstable test MySqlSyncTableActionITCase#testSyncShards (a…

…pache#3096)
zhuangchong · Mar 26, 2024 · 860b021 · 860b021
1 parent 2db9558
commit 860b021
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/...link-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java b/...link-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java
@@ -101,9 +101,10 @@ protected Schema retrieveSchema() throws Exception {
     @Override
     protected MySqlSource<String> buildSource() {
         String tableList =
-                cdcSourceConfig.get(MySqlSourceOptions.DATABASE_NAME)
-                        + "\\."
-                        + cdcSourceConfig.get(MySqlSourceOptions.TABLE_NAME);
+                String.format(
+                        "(%s)\\.(%s)",
+                        cdcSourceConfig.get(MySqlSourceOptions.DATABASE_NAME),
+                        cdcSourceConfig.get(MySqlSourceOptions.TABLE_NAME));
         return MySqlActionUtils.buildMySqlSource(cdcSourceConfig, tableList, typeMapping);
     }