[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 <qhj00725@qq.com>
apache · Sep 25, 2023 · 3c1f448 · 3c1f448
1 parent 1b327f8
commit 3c1f448
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/...er-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java b/...er-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java
@@ -23,7 +23,6 @@
 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 void deleteOpt(StreamSinkEntity entity, String operator) {
     @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;