commit 6673462c809eb3032a4e4cabed8250ad80c790cb
author yulei0824 <yulei0824@163.com> Thu Mar 07 15:09:46 2024 +0800
committer GitHub <noreply@github.com> Thu Mar 07 15:09:46 2024 +0800
tree 12f71f81a60e46b74731829373ef203b2f4f402e
parent f8e61bab004210a3bb33ff173f06205491788c41

[Bug] Fix the invalid options --table-prefix and --table-suffix (#332)

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
index 3291b4c..6b0a0fd 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
@@ -321,6 +321,8 @@
                 .setTableMapping(tableMapping)
                 .setTableProperties(tableConfig)
                 .setTargetDatabase(database)
+                .setTargetTablePrefix(tablePrefix)
+                .setTargetTableSuffix(tableSuffix)
                 .build();
     }