[INLONG-11881][Manager] Sink source field supports configuring the function function (#11882)

Author: fuweng11

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.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 @@ private SourceConfig getSourceConfig(InlongGroupInfo groupInfo, InlongStreamInfo
                 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());