Commit 994e5460 by guo_minglei@163.com

修改判断方式

parent e36a4328
...@@ -362,7 +362,7 @@ public class FlowServiceImpl implements FlowService { ...@@ -362,7 +362,7 @@ public class FlowServiceImpl implements FlowService {
//杀死所有的任务 //杀死所有的任务
List<JobTaskRunLog> jobTaskRunLogList = jobTaskRunLogMapper.findByRunId(runId); List<JobTaskRunLog> jobTaskRunLogList = jobTaskRunLogMapper.findByRunId(runId);
for (JobTaskRunLog jobTaskRunLog : jobTaskRunLogList){ for (JobTaskRunLog jobTaskRunLog : jobTaskRunLogList){
if (!"0".equals(jobTaskRunLog.getRunCode())){ if ("0".equals(jobTaskRunLog.getRunCode())){
if (StringUtils.isEmpty(jobTaskRunLog.getJobGroupIp())){ if (StringUtils.isEmpty(jobTaskRunLog.getJobGroupIp())){
log.warn("已经调度成功但是还未返回具体的调用机器的ip地址"); log.warn("已经调度成功但是还未返回具体的调用机器的ip地址");
Thread.sleep(3000); Thread.sleep(3000);
......
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