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 3291b4ca1..6b0a0fdb3 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 DorisRecordSerializer buildSchemaSerializer( .setTableMapping(tableMapping) .setTableProperties(tableConfig) .setTargetDatabase(database) + .setTargetTablePrefix(tablePrefix) + .setTargetTableSuffix(tableSuffix) .build(); }