Commit 74eb75a4 by huangfu

虚节点不需要

parent 49fa5c96
...@@ -106,8 +106,13 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper { ...@@ -106,8 +106,13 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper {
//删除这个数据 并且添加到日志 //删除这个数据 并且添加到日志
try { try {
taskAndLogServer.addRunLogAndRemoveTask(jobTask,true,false); taskAndLogServer.addRunLogAndRemoveTask(jobTask,true,false);
} catch (UnknownHostException e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
try {
taskAndLogServer.addRunLogAndRemoveTask(jobTask,true,true, MythLogUtils.getMessage(e));
} catch (UnknownHostException unknownHostException) {
unknownHostException.printStackTrace();
}
} }
} catch (Exception e) { } catch (Exception e) {
log.error("-----------------节点执行时出现异常,{}----------", MythLogUtils.getMessage(e)); log.error("-----------------节点执行时出现异常,{}----------", MythLogUtils.getMessage(e));
...@@ -137,12 +142,17 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper { ...@@ -137,12 +142,17 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper {
//删除这个数据 并且添加到日志 //删除这个数据 并且添加到日志
try { try {
taskAndLogServer.addRunLogAndRemoveTask(jobTask,false,false); taskAndLogServer.addRunLogAndRemoveTask(jobTask,false,false);
} catch (UnknownHostException e) { } catch (Exception e) {
log.error("-----------------节点执行时出现异常,{}----------",MythLogUtils.getMessage(e)); log.error("-----------------节点执行时出现异常,{}----------",MythLogUtils.getMessage(e));
try {
taskAndLogServer.addRunLogAndRemoveTask(jobTask,false,true, MythLogUtils.getMessage(e));
} catch (UnknownHostException unknownHostException) {
unknownHostException.printStackTrace();
}
} }
}catch (Exception businessException) { }catch (Exception businessException) {
try { try {
taskAndLogServer.addRunLogAndRemoveTask(jobTask,false,true); taskAndLogServer.addRunLogAndRemoveTask(jobTask,false,true,MythLogUtils.getMessage(businessException));
} catch (UnknownHostException e) { } catch (UnknownHostException e) {
log.error("-----------------节点执行时出现异常,{}----------",MythLogUtils.getMessage(e)); log.error("-----------------节点执行时出现异常,{}----------",MythLogUtils.getMessage(e));
} }
......
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