Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
DolphinScheduler
提交
59685d88
DolphinScheduler
项目概览
apache
/
DolphinScheduler
上一次同步 1 年多
通知
704
Star
9572
Fork
3514
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
DolphinScheduler
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
未验证
提交
59685d88
编写于
4月 25, 2021
作者:
K
Kirs
提交者:
GitHub
4月 25, 2021
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[1.3.6-prepare]work flow would running if task is killed by manual. (#5363)
pr #5362 issue #5349
上级
709dfe27
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
8 addition
and
3 deletion
+8
-3
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/DependResult.java
...rg/apache/dolphinscheduler/common/enums/DependResult.java
+2
-1
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java
...lphinscheduler/server/master/runner/MasterExecThread.java
+6
-2
未找到文件。
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/DependResult.java
浏览文件 @
59685d88
...
...
@@ -26,6 +26,7 @@ public enum DependResult {
* 0 success
* 1 waiting
* 2 failed
* 3 non execution
*/
SUCCESS
,
WAITING
,
FAILED
SUCCESS
,
WAITING
,
FAILED
,
NON_EXEC
}
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java
浏览文件 @
59685d88
...
...
@@ -527,7 +527,7 @@ public class MasterExecThread implements Runnable {
}
ExecutionStatus
depTaskState
=
completeTaskList
.
get
(
depsNode
).
getState
();
if
(
depTaskState
.
typeIsPause
()
||
depTaskState
.
typeIsCancel
()){
return
DependResult
.
WAITING
;
return
DependResult
.
NON_EXEC
;
}
// ignore task state if current task is condition
if
(
taskNode
.
isConditionsTask
()){
...
...
@@ -1017,7 +1017,11 @@ public class MasterExecThread implements Runnable {
dependFailedTask
.
put
(
task
.
getName
(),
task
);
removeTaskFromStandbyList
(
task
);
logger
.
info
(
"task {},id:{} depend result : {}"
,
task
.
getName
(),
task
.
getId
(),
dependResult
);
}
}
else
if
(
DependResult
.
NON_EXEC
==
dependResult
)
{
// for some reasons(depend task pause/stop) this task would not be submit
removeTaskFromStandbyList
(
task
);
logger
.
info
(
"remove task {},id:{} , because depend result : {}"
,
task
.
getName
(),
task
.
getId
(),
dependResult
);
}
}
}
catch
(
Exception
e
)
{
logger
.
error
(
"submit standby task error"
,
e
);
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录