fixed

apache · Mar 27, 2024 · dd5d186 · dd5d186
1 parent 036366f
commit dd5d186
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 10 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/utils/JsonSerdeUtil.java b/paimon-core/src/main/java/org/apache/paimon/utils/JsonSerdeUtil.java
@@ -35,7 +35,6 @@
 import org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.SerializerProvider;
 import org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.deser.std.StdDeserializer;
 import org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.module.SimpleModule;
-import org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.node.ArrayNode;
 import org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.node.ObjectNode;
 import org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.ser.std.StdSerializer;
 
@@ -44,7 +43,6 @@
 import java.io.IOException;
 import java.io.UncheckedIOException;
 import java.util.LinkedHashMap;
-import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 
@@ -131,13 +129,10 @@ public static <T> T fromJson(String json, TypeReference<T> typeReference) {
         }
     }
 
-    public static ObjectNode appendArrayNode(
-            ObjectNode node, String fieldName, List<String> elememts) {
-        ArrayNode arrayNode = OBJECT_MAPPER_INSTANCE.createArrayNode();
-        for (String element : elememts) {
-            arrayNode.add(element);
-        }
-        node.set(fieldName, arrayNode);
+    public static <T> ObjectNode setNode(ObjectNode node, String fieldName, T value) {
+        ObjectMapper mapper = new ObjectMapper();
+        JsonNode nodeValue = OBJECT_MAPPER_INSTANCE.valueToTree(value);
+        node.set(fieldName, nodeValue);
         return node;
     }
 

diff --git a/...src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumSchemaUtils.java b/...src/main/java/org/apache/paimon/flink/action/cdc/format/debezium/DebeziumSchemaUtils.java
@@ -84,7 +84,7 @@ public static String extractPrimaryKeys(Pair<String, String> record) {
             ObjectNode valueNode = JsonSerdeUtil.fromJson(record.getValue(), ObjectNode.class);
 
             // append primary keys
-            JsonSerdeUtil.appendArrayNode(valueNode, FIELD_PRIMARY, primaryKeys);
+            JsonSerdeUtil.setNode(valueNode, FIELD_PRIMARY, primaryKeys);
             return JsonSerdeUtil.writeValueAsString(valueNode);
         } catch (JsonProcessingException e) {
             throw new RuntimeException(