You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ca...@apache.org on 2022/02/16 09:38:51 UTC
[dolphinscheduler] branch dev updated: [Fix-Typo] Fix typo in dev branch. (#8395)
This is an automated email from the ASF dual-hosted git repository.
caishunfeng 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 864ceb1 [Fix-Typo] Fix typo in dev branch. (#8395)
864ceb1 is described below
commit 864ceb164f1769d29afccac40e88add594477b69
Author: xiangzihao <46...@qq.com>
AuthorDate: Wed Feb 16 17:38:43 2022 +0800
[Fix-Typo] Fix typo in dev branch. (#8395)
* fix bug_8337
* fix bug_8337
* fix bug_8337
* fix bug_8337
* fix bug_8337
* fix bug_8337
* fix bug_8337
* test
* fix dev_bug_8337
* fix dev_bug_8337
* fix dev_bug_8337
* fix bug_8337
* fix typo
---
.../dolphinscheduler/server/master/runner/WorkflowExecuteThread.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
index 676bb03..c8c15ae 100644
--- a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
+++ b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/WorkflowExecuteThread.java
@@ -1463,10 +1463,10 @@ public class WorkflowExecuteThread {
if (state == ExecutionStatus.READY_STOP) {
List<TaskInstance> stopList = getCompleteTaskByState(ExecutionStatus.STOP);
List<TaskInstance> killList = getCompleteTaskByState(ExecutionStatus.KILL);
- List<TaskInstance> faillist = getCompleteTaskByState(ExecutionStatus.FAILURE);
+ List<TaskInstance> failList = getCompleteTaskByState(ExecutionStatus.FAILURE);
if (CollectionUtils.isNotEmpty(stopList)
|| CollectionUtils.isNotEmpty(killList)
- || CollectionUtils.isNotEmpty(faillist)
+ || CollectionUtils.isNotEmpty(failList)
|| !isComplementEnd()) {
return ExecutionStatus.STOP;
} else {