[inlong] branch master updated: [INLONG-8986][Manager] Sortstandalone get params from manager error (#8987)

[vernedeng]

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

vernedeng 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 3c1f448927 [INLONG-8986][Manager] Sortstandalone get params from 
manager error (#8987)
3c1f448927 is described below

commit 3c1f448927758a182c89753fae6c39d50a5fcfd7
Author: castor <58140421+castor...@users.noreply.github.com>
AuthorDate: Mon Sep 25 13:22:02 2023 +0800

    [INLONG-8986][Manager] Sortstandalone get params from manager error (#8987)
    
    * [Manager] Sort standalone get params from manager error
    
    * [Manager] Fix Sort standalone get params from manager error
    
    ---------
    
    Co-authored-by: castorqin <qhj00...@qq.com>
---
 .../org/apache/inlong/manager/service/sink/AbstractSinkOperator.java | 5 -----
 1 file changed, 5 deletions(-)

diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java
index 44d8a58752..57b241cfcf 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java
@@ -23,7 +23,6 @@ import org.apache.inlong.manager.common.enums.SinkStatus;
 import org.apache.inlong.manager.common.exceptions.BusinessException;
 import org.apache.inlong.manager.common.util.CommonBeanUtils;
 import org.apache.inlong.manager.common.util.JsonUtils;
-import org.apache.inlong.manager.dao.entity.InlongStreamEntity;
 import org.apache.inlong.manager.dao.entity.StreamSinkEntity;
 import org.apache.inlong.manager.dao.entity.StreamSinkFieldEntity;
 import org.apache.inlong.manager.dao.mapper.InlongStreamEntityMapper;
@@ -221,14 +220,10 @@ public abstract class AbstractSinkOperator implements 
StreamSinkOperator {
     @Override
     public Map<String, String> parse2IdParams(StreamSinkEntity streamSink, 
List<String> fields) {
         Map<String, String> param;
-        InlongStreamEntity inlongStreamEntity = 
inlongStreamEntityMapper.selectByIdentifier(
-                streamSink.getInlongGroupId(), streamSink.getInlongStreamId());
         try {
             param = JsonUtils.parseObject(streamSink.getExtParams(), 
HashMap.class);
             // put group and stream info
             assert param != null;
-            param.put(KEY_SEPARATOR, inlongStreamEntity.getDataSeparator());
-            param.put(KEY_DATA_TYPE, inlongStreamEntity.getDataType());
             param.put(KEY_GROUP_ID, streamSink.getInlongGroupId());
             param.put(KEY_STREAM_ID, streamSink.getInlongStreamId());
             return param;