From a7207fb892e1570dfc3e55a124fbf1937bdb81a4 Mon Sep 17 00:00:00 2001 From: iture123 Date: Wed, 7 Sep 2022 00:09:28 +0800 Subject: [PATCH] [Feature][Connector-V2]fix JsonNode convert to Map(#2553) --- .../seatunnel/elasticsearch/client/EsRestClient.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java index e943a4d8af4..3cf0807484d 100644 --- a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java +++ b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java @@ -29,6 +29,7 @@ import org.apache.seatunnel.shade.com.typesafe.config.Config; +import com.fasterxml.jackson.core.type.TypeReference; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.node.ObjectNode; @@ -61,6 +62,8 @@ public class EsRestClient { private final RestClient restClient; + private final ObjectMapper mapper = new ObjectMapper(); + private EsRestClient(RestClient restClient) { this.restClient = restClient; } @@ -227,7 +230,7 @@ private ScrollResult getDocsFromScrollResponse(ObjectNode responseJson) { JsonNode hitNode = iter.next(); doc.put("_index", hitNode.get("_index").textValue()); doc.put("_id", hitNode.get("_id").textValue()); - Map source = JsonUtils.parseObject(hitNode.get("_source").toPrettyString(), Map.class); + Map source = mapper.convertValue(hitNode.get("_source"), new TypeReference>(){}); doc.putAll(source); docs.add(doc); }