This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new de65d531a [hotfix] Fix that MySQL sync-database action parses table
prefix incorrectly (#1868)
de65d531a is described below
commit de65d531a7be1d3219c60a38c0ff9b7d0aa26fc1
Author: yuzelin <[email protected]>
AuthorDate: Wed Aug 23 20:44:30 2023 +0800
[hotfix] Fix that MySQL sync-database action parses table prefix
incorrectly (#1868)
---
.../paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java
index a7a092bbb..dac6e0f0f 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java
@@ -53,7 +53,7 @@ public class MySqlSyncDatabaseActionFactory implements
ActionFactory {
.mergeShards(
!params.has("merge-shards")
||
Boolean.parseBoolean(params.get("merge-shards")))
- .withTablePrefix(params.get("table-suffix"))
+ .withTablePrefix(params.get("table-prefix"))
.withTableSuffix(params.get("table-suffix"))
.includingTables(params.get("including-tables"))
.excludingTables(params.get("excluding-tables"))
