fix

yuzelin · Jun 20, 2024 · 94d6243 · 94d6243
1 parent 89cd0e6
commit 94d6243
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...aimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/NewTableSchemaBuilder.java b/...aimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/NewTableSchemaBuilder.java
@@ -67,7 +67,7 @@ public Optional<Schema> build(RichCdcMultiplexRecord record) {
                         Collections.emptyList(),
                         tableConfig,
                         sourceSchema,
-                        new CdcMetadataConverter[0],
+                        metadataConverters,
                         caseSensitive,
                         false,
                         true));