Commit 2eeafe95 by huangfusuper

··

parent 79894bbf
...@@ -110,8 +110,9 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement ...@@ -110,8 +110,9 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement
*/ */
private boolean logIsAllEnd(List<JobTaskRunLogWithBLOBs> jobTaskRunLogs){ private boolean logIsAllEnd(List<JobTaskRunLogWithBLOBs> jobTaskRunLogs){
for (JobTaskRunLogWithBLOBs jobTaskRunLog : jobTaskRunLogs) { for (JobTaskRunLogWithBLOBs jobTaskRunLog : jobTaskRunLogs) {
if (!(NodeRunStatusPropertyEnum.RUN_SUCCESS.getCode().equals(jobTaskRunLog.getRunCode()) || if (NodeRunStatusPropertyEnum.RUN_ING.getCode().equals(jobTaskRunLog.getRunCode())) {
NodeRunStatusPropertyEnum.RE_RUN_SUCCESS.getCode().equals(jobTaskRunLog.getRunCode()))){ log.debug("--------------节点{},正在运行中-----------",jobTaskRunLog);
//存在运行中的直接返回false
return false; return false;
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment