From 94d6243d2b26577bbf45aedccc4ec10048f08eaa Mon Sep 17 00:00:00 2001 From: yuzelin Date: Thu, 20 Jun 2024 17:59:47 +0800 Subject: [PATCH] fix --- .../org/apache/paimon/flink/sink/cdc/NewTableSchemaBuilder.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/NewTableSchemaBuilder.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/NewTableSchemaBuilder.java index 3c526c7b79af..33dfd576fde6 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/NewTableSchemaBuilder.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/NewTableSchemaBuilder.java @@ -67,7 +67,7 @@ public Optional build(RichCdcMultiplexRecord record) { Collections.emptyList(), tableConfig, sourceSchema, - new CdcMetadataConverter[0], + metadataConverters, caseSensitive, false, true));