From 907bb875c6345528103f76aa39bd04859eb6276e Mon Sep 17 00:00:00 2001 From: wudi <676366545@qq.com> Date: Tue, 5 Dec 2023 09:59:31 +0800 Subject: [PATCH] fix --- .../doris/flink/sink/writer/serializer/RowDataSerializer.java | 1 + 1 file changed, 1 insertion(+) diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataSerializer.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataSerializer.java index a9830a5ab..696e4c740 100644 --- a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataSerializer.java +++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataSerializer.java @@ -72,6 +72,7 @@ public DorisRecord serialize(RowData record) throws IOException{ return DorisRecord.of(valString.getBytes(StandardCharsets.UTF_8)); } + public String buildJsonString(RowData record, int maxIndex) throws IOException { int fieldIndex = 0; Map valueMap = new HashMap<>();