This is an automated email from the ASF dual-hosted git repository. healchow pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git
commit 2247d7d5b0150d4984a6c518af6ee396d6287185 Author: woofyzhao <[email protected]> AuthorDate: Thu Oct 13 17:45:17 2022 +0800 [INLONG-6171][Manager] Fix the lightweight group union nodes relation error (#6172) --- .../service/resource/sort/DefaultSortConfigOperator.java | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 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 6096777ac..a4c6b5d80 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 @@ -123,18 +123,22 @@ public class DefaultSortConfigOperator implements SortConfigOperator { List<StreamSource> sources = sourceMap.get(streamId); List<StreamSink> sinks = sinkMap.get(streamId); List<NodeRelation> relations; - if (CollectionUtils.isEmpty(transformResponses)) { - relations = NodeRelationUtils.createNodeRelations(sources, sinks); - } else { - relations = NodeRelationUtils.createNodeRelations(inlongStream); - // in standard mode, replace upstream source node and transform input fields node to mq node - if (InlongConstants.STANDARD_MODE.equals(groupInfo.getLightweight())) { + + if (InlongConstants.STANDARD_MODE.equals(groupInfo.getLightweight())) { + if (CollectionUtils.isNotEmpty(transformResponses)) { + relations = NodeRelationUtils.createNodeRelations(inlongStream); + + // in standard mode, replace upstream source node and transform input fields node to mq node // mq node name, which is inlong stream id String mqNodeName = sources.get(0).getSourceName(); Set<String> nodeNameSet = getInputNodeNames(sources, transformResponses); adjustTransformField(transformResponses, nodeNameSet, mqNodeName); adjustNodeRelations(relations, nodeNameSet, mqNodeName); + } else { + relations = NodeRelationUtils.createNodeRelations(sources, sinks); } + } else { + relations = NodeRelationUtils.createNodeRelations(inlongStream); } // create extract-transform-load nodes
