(inlong) branch master updated: [INLONG-11881][Manager] Sink source field supports configuring the function function (#11882)

[wakefu]

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

wakefu 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 7b47d041ca [INLONG-11881][Manager] Sink source field supports 
configuring the function function (#11882)
7b47d041ca is described below

commit 7b47d041ca18e508d988fb20eef3467f2a824065
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Mon Jun 9 14:07:10 2025 +0800

    [INLONG-11881][Manager] Sink source field supports configuring the function 
function (#11882)
---
 .../manager/service/resource/sort/DefaultSortConfigOperator.java  | 8 +++-----
 1 file changed, 3 insertions(+), 5 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 17ca4b9bad..30f75c45df 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
@@ -36,7 +36,6 @@ import org.apache.inlong.manager.common.util.CommonBeanUtils;
 import org.apache.inlong.manager.common.util.Preconditions;
 import org.apache.inlong.manager.dao.entity.InlongClusterEntity;
 import org.apache.inlong.manager.dao.entity.SortConfigEntity;
-import org.apache.inlong.manager.dao.entity.StreamSinkFieldEntity;
 import org.apache.inlong.manager.dao.mapper.InlongClusterEntityMapper;
 import org.apache.inlong.manager.dao.mapper.InlongGroupEntityMapper;
 import org.apache.inlong.manager.dao.mapper.SortConfigEntityMapper;
@@ -252,13 +251,12 @@ public class DefaultSortConfigOperator implements 
SortConfigOperator {
                 
dataTypeOperatorFactory.getInstance(DataTypeEnum.forType(streamInfo.getDataType()));
         DataTypeConfig dataTypeConfig = 
dataTypeOperator.getDataTypeConfig(streamInfo);
         SourceConfig sourceConfig = new SourceConfig();
-        List<StreamSinkFieldEntity> sinkFieldEntities = 
sinkFieldMapper.selectBySinkId(sink.getId());
-        List<FieldConfig> fields = sinkFieldEntities.stream().map(
+        List<FieldConfig> fields = streamInfo.getFieldList().stream().map(
                 v -> {
                     FieldConfig fieldConfig = new FieldConfig();
                     FormatInfo formatInfo = FieldInfoUtils.convertFieldFormat(
-                            v.getSourceFieldType().toLowerCase());
-                    fieldConfig.setName(v.getSourceFieldName());
+                            v.getFieldType().toLowerCase());
+                    fieldConfig.setName(v.getFieldName());
                     fieldConfig.setFormatInfo(formatInfo);
                     return fieldConfig;
                 }).collect(Collectors.toList());