【BUG-5328】 modify process contain depend task is always running (#5344)

Co-authored-by: N wanghong1314 <wanghong1@onething.net>

【BUG-5328】 modify process contain depend task is always running (#5344)
Co-authored-by: N wanghong1314 <wanghong1@onething.net>
e12a2628 · wanghong1314 · GitHub · 5f1fc462 · e12a2628
隐藏空白更改
内联并排

Showing with 2 addition and 1 deletion

dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java ...ache/dolphinscheduler/service/process/ProcessService.java +2 -1

未找到文件。
--- 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<TaskInstance> 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;
            }
        }