[inlong] branch master updated: [INLONG-6146][Manager] Fix error jackson dependency when build dataflow json string (#6147)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new af1ffa8bd [INLONG-6146][Manager] Fix error jackson dependency when 
build dataflow json string (#6147)
af1ffa8bd is described below

commit af1ffa8bdd3a6a5e175e30727db329cdab1406ca
Author: Xin Gong <genzhedangd...@gmail.com>
AuthorDate: Wed Oct 12 10:28:16 2022 +0800

    [INLONG-6146][Manager] Fix error jackson dependency when build dataflow 
json string (#6147)
---
 .../manager/service/resource/sort/DefaultSortConfigOperator.java     | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/DefaultSortConfigOperator.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/DefaultSortConfigOperator.java
index 790e46049..6096777ac 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/DefaultSortConfigOperator.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/DefaultSortConfigOperator.java
@@ -18,8 +18,8 @@
 package org.apache.inlong.manager.service.resource.sort;
 
 import org.apache.commons.collections.CollectionUtils;
+import 
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.inlong.manager.common.consts.InlongConstants;
-import org.apache.inlong.manager.common.util.JsonUtils;
 import org.apache.inlong.manager.pojo.group.InlongGroupExtInfo;
 import org.apache.inlong.manager.pojo.group.InlongGroupInfo;
 import org.apache.inlong.manager.pojo.sink.StreamSink;
@@ -60,6 +60,7 @@ import java.util.stream.Collectors;
 public class DefaultSortConfigOperator implements SortConfigOperator {
 
     private static final Logger LOGGER = 
LoggerFactory.getLogger(DefaultSortConfigOperator.class);
+    private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
 
     @Autowired
     private StreamSourceService sourceService;
@@ -82,7 +83,7 @@ public class DefaultSortConfigOperator implements 
SortConfigOperator {
         }
 
         GroupInfo configInfo = this.getGroupInfo(groupInfo, streamInfos);
-        String dataflow = JsonUtils.toJsonString(configInfo);
+        String dataflow = OBJECT_MAPPER.writeValueAsString(configInfo);
         if (isStream) {
             this.addToStreamExt(streamInfos, dataflow);
         } else {