You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by we...@apache.org on 2022/08/02 01:30:29 UTC
[dolphinscheduler] branch dev updated: Fix recovery from failed task will dead loop (#11239)
This is an automated email from the ASF dual-hosted git repository.
wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new 04f3aa9713 Fix recovery from failed task will dead loop (#11239)
04f3aa9713 is described below
commit 04f3aa97135d79469daf7c21c935029faff827b2
Author: Wenjun Ruan <we...@apache.org>
AuthorDate: Tue Aug 2 09:30:18 2022 +0800
Fix recovery from failed task will dead loop (#11239)
---
.../server/master/runner/WorkflowExecuteRunnable.java | 12 +++++++-----
1 file changed, 7 insertions(+), 5 deletions(-)
diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java
index f2965f79f5..7f98e07453 100644
--- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java
+++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteRunnable.java
@@ -83,7 +83,6 @@ import org.apache.dolphinscheduler.service.process.ProcessService;
import org.apache.dolphinscheduler.service.queue.PeerTaskInstancePriorityQueue;
import org.apache.commons.collections.CollectionUtils;
-import org.apache.commons.lang3.ArrayUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.math.NumberUtils;
@@ -1818,10 +1817,13 @@ public class WorkflowExecuteRunnable implements Callable<WorkflowSubmitStatue> {
// todo: Can we use a better way to set the recover taskInstanceId list? rather then use the cmdParam
if (paramMap != null && paramMap.containsKey(CMD_PARAM_RECOVERY_START_NODE_STRING)) {
- String[] idList = paramMap.get(CMD_PARAM_RECOVERY_START_NODE_STRING).split(Constants.COMMA);
- if (ArrayUtils.isNotEmpty(idList)) {
- List<Integer> taskInstanceIds = Arrays.stream(idList).map(Integer::valueOf).collect(Collectors.toList());
- return processService.findTaskInstanceByIdList(taskInstanceIds);
+ List<Integer> startTaskInstanceIds = Arrays.stream(paramMap.get(CMD_PARAM_RECOVERY_START_NODE_STRING)
+ .split(COMMA))
+ .filter(StringUtils::isNotEmpty)
+ .map(Integer::valueOf)
+ .collect(Collectors.toList());
+ if (CollectionUtils.isNotEmpty(startTaskInstanceIds)) {
+ return processService.findTaskInstanceByIdList(startTaskInstanceIds);
}
}
return Collections.emptyList();