From e12a26289bce0b38bd65ac74a3349ecadd8a9141 Mon Sep 17 00:00:00 2001 From: wanghong1314 <498213175@qq.com> Date: Wed, 21 Apr 2021 22:29:53 +0800 Subject: [PATCH] =?UTF-8?q?=E3=80=90BUG-5328=E3=80=91=20modify=20process?= =?UTF-8?q?=20contain=20depend=20task=20is=20always=20running=20(#5344)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: wanghong1314 --- .../dolphinscheduler/service/process/ProcessService.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java index 1f48821321..49c64bea48 100644 --- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java +++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java @@ -1264,7 +1264,8 @@ public class ProcessService { List taskInstances = this.findValidTaskListByProcessId(taskInstance.getProcessInstanceId()); for (TaskInstance task : taskInstances) { - if (task.getState() == ExecutionStatus.FAILURE) { + if (task.getState() == ExecutionStatus.FAILURE + && task.getRetryTimes() >= task.getMaxRetryTimes()) { return false; } }