This is an automated email from the ASF dual-hosted git repository.
caishunfeng pushed a commit to branch 2.0.4-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/2.0.4-prepare by this push:
new 9e133a2 fix relation unbinding bug (#8381)
9e133a2 is described below
commit 9e133a2f50b73fa7b793683a0ff36287491c52af
Author: JinYong Li <[email protected]>
AuthorDate: Thu Feb 17 15:02:19 2022 +0800
fix relation unbinding bug (#8381)
---
.../api/service/impl/ProcessTaskRelationServiceImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessTaskRelationServiceImpl.java
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessTaskRelationServiceImpl.java
index 5761584..27855ed 100644
---
a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessTaskRelationServiceImpl.java
+++
b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessTaskRelationServiceImpl.java
@@ -214,7 +214,7 @@ public class ProcessTaskRelationServiceImpl extends
BaseServiceImpl implements P
return result;
}
List<Long> downstreamList = Lists.newArrayList();
- for (ProcessTaskRelation processTaskRelation :
processTaskRelationList) {
+ for (ProcessTaskRelation processTaskRelation : processTaskRelations) {
if (processTaskRelation.getPreTaskCode() == taskCode) {
downstreamList.add(processTaskRelation.getPostTaskCode());
}
