diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java index 36feefd3c3bb..50b306bb03d6 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableAction.java @@ -100,10 +100,10 @@ protected Schema retrieveSchema() throws Exception { @Override protected MySqlSource buildSource() { - String tableList = - cdcSourceConfig.get(MySqlSourceOptions.DATABASE_NAME) - + "\\." - + cdcSourceConfig.get(MySqlSourceOptions.TABLE_NAME); + String tableList = + cdcSourceConfig.get(MySqlSourceOptions.DATABASE_NAME) + + "\\." + + cdcSourceConfig.get(MySqlSourceOptions.TABLE_NAME); return MySqlActionUtils.buildMySqlSource(cdcSourceConfig, tableList, typeMapping); }