This is an automated email from the ASF dual-hosted git repository.

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new 6673462  [Bug] Fix the invalid options --table-prefix and 
--table-suffix (#332)
6673462 is described below

commit 6673462c809eb3032a4e4cabed8250ad80c790cb
Author: yulei0824 <yulei0...@163.com>
AuthorDate: Thu Mar 7 15:09:46 2024 +0800

    [Bug] Fix the invalid options --table-prefix and --table-suffix (#332)
---
 .../src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java    | 2 ++
 1 file changed, 2 insertions(+)

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 @@ public abstract class DatabaseSync {
                 .setTableMapping(tableMapping)
                 .setTableProperties(tableConfig)
                 .setTargetDatabase(database)
+                .setTargetTablePrefix(tablePrefix)
+                .setTargetTableSuffix(tableSuffix)
                 .build();
     }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to