Commit 6cd48c0f by huangfusuper

解决开始节点异常不能够被捕获的BUG

parent e69d8531
...@@ -121,12 +121,11 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper { ...@@ -121,12 +121,11 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper {
} }
} }
} else { } else {
try {
//先处理开始节点 //先处理开始节点
if(NodeNameEnum.START_NODE.getNodeName().equals(jobTask.getNodeName())){ if(NodeNameEnum.START_NODE.getNodeName().equals(jobTask.getNodeName())){
startNodeOperating(jobTask,jobTaskSchedules); startNodeOperating(jobTask,jobTaskSchedules);
}else { }else {
//普通节点
try {
//如果是补批节点 而且没有依赖节点的话,按照开始节点处理 //如果是补批节点 而且没有依赖节点的话,按照开始节点处理
if( ScheduleTypeEnum.REPAIR.getCode().equals(jobTask.getScheduleType()) && StringUtils.isBlank(jobTask.getNodeDepend())){ if( ScheduleTypeEnum.REPAIR.getCode().equals(jobTask.getScheduleType()) && StringUtils.isBlank(jobTask.getNodeDepend())){
startNodeOperating(jobTask,jobTaskSchedules); startNodeOperating(jobTask,jobTaskSchedules);
...@@ -136,6 +135,7 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper { ...@@ -136,6 +135,7 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper {
//断定上级节点是否执行成功 //断定上级节点是否执行成功
runJobTask(jobTask,jobTaskSchedules); runJobTask(jobTask,jobTaskSchedules);
} }
}
}catch (SuperiorNodeRunException se) { }catch (SuperiorNodeRunException se) {
//删除这个数据 并且添加到日志 //删除这个数据 并且添加到日志
try { try {
...@@ -150,7 +150,7 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper { ...@@ -150,7 +150,7 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper {
log.error("-----------------节点执行时出现异常,{}----------",e.getMessage()); log.error("-----------------节点执行时出现异常,{}----------",e.getMessage());
} }
} }
}
} }
} }
//执行保存到排表 删除任务表操作 //执行保存到排表 删除任务表操作
......
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