[Bug] Fix the invalid options --table-prefix and --table-suffix (apac…

…he#332)
JNSimba · Mar 7, 2024 · 6673462 · 6673462
1 parent f8e61ba
commit 6673462
Showing 1 changed file with 2 additions and 0 deletions.
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
@@ -321,6 +321,8 @@ public DorisRecordSerializer<String> buildSchemaSerializer(
                 .setTableMapping(tableMapping)
                 .setTableProperties(tableConfig)
                 .setTargetDatabase(database)
+                .setTargetTablePrefix(tablePrefix)
+                .setTargetTableSuffix(tableSuffix)
                 .build();
     }