杀死失败时报错提示

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/impl/FlowServiceImpl.java

@@ -331,7 +331,7 @@ public class FlowServiceImpl implements FlowService {
                         ValidationUtil.isTrueValidation(!"0".equals(innerJobTaskRunLog.getRunCode()), "该任务已经运行结束！");
                         ValidationUtil.dataNotBank(innerJobTaskRunLog.getJobGroupIp(), "尚未分配执行机请稍后再试");
                     }
-                    if (! killJob(innerJobTaskRunLog.getLogId(), innerJobTaskRunLog.getJobGroupIp())){
+                    if (!killJob(innerJobTaskRunLog.getLogId(), innerJobTaskRunLog.getJobGroupIp())){
                         result = false;
                     }
                 }
@@ -386,10 +386,9 @@ public class FlowServiceImpl implements FlowService {
         String killResult = HttpUtil.post(killUrl, requestMap);
         log.info("请求结果{}", killResult);
         ResponseResult responseResult = JSON.parseObject(killResult, ResponseResult.class);
-        if ("SUCCESS".equals(responseResult.getResult())){
+        ValidationUtil.isTrueValidation(!"SUCCESS".equals(responseResult.getResult()), "杀死job失败，错误信息为：" + responseResult.getResult());
+
         return true;
     }
-        return false;
-    }
 
 }
\ No newline at end of file

byit-myth-executor/myth-executor-server/src/main/java/com/byit/process/MythJobProcess.java

@@ -234,6 +234,7 @@ public class MythJobProcess implements Callable<String>{
      * 强制杀死这个过程
      */
     public void hardKill() {
+        log.info("强制杀死这个过程");
         //判断是否已经开始运行
         checkStarted();
         //判断是否正在执行