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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
