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

…3096)
apache · Mar 26, 2024 · c6cb0c2 · c6cb0c2
1 parent 9839efa
commit c6cb0c2
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);
     }