修正重启停止节点报错

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

@@ -517,13 +517,20 @@ public class FlowServiceImpl implements FlowService {
         String killUrl = "http://" + exectUrl + "/myth-executor-server/processManager/killJob";
         Map<String, Object> requestMap = new HashMap<>(2);
         requestMap.put("logId", logId);
-        String killResult = HttpUtil.post(killUrl, requestMap);
-        log.info("请求结果{}", killResult);
-        ResponseResult responseResult = JSON.parseObject(killResult, ResponseResult.class);
-        if (!"SUCCESS".equals(responseResult.getResult())) {
-            errorMsg.append("【").append(nodeName).append("】杀死失败，错误信息为:").append(responseResult.getMsg());
+        try{
+            String killResult = HttpUtil.post(killUrl, requestMap);
+            log.info("请求结果{}", killResult);
+            ResponseResult responseResult = JSON.parseObject(killResult, ResponseResult.class);
+            if (!"SUCCESS".equals(responseResult.getResult())) {
+                errorMsg.append("【").append(nodeName).append("】杀死失败，错误信息为:").append(responseResult.getMsg());
+                return false;
+            }
+        }catch (Exception e) {
+            errorMsg.append("【").append(nodeName).append("】杀死失败，错误信息为:").append(e.getMessage());
             return false;
         }
+
+
         return true;
     }
 

byit-myth-executor/myth-executor-server/src/main/java/com/byit/node/impl/CommandAndScriptProcessingMachine.java

@@ -60,7 +60,7 @@ public class CommandAndScriptProcessingMachine implements ProcessingMachine {
             }
             //判断是否需要拉取文件服务器的文件,包含biz_file的条件下会对这个字段进行替换
             if (StringUtils.isNoneBlank(scriptDto.getRemotePath())) {
-                //这里需要解压压缩包  然后将
+                //这里需要解压压缩包  然后将压缩包删除
                 String scriptDirPath = byteArrayToSource(scriptDto.getRemotePath());
                 log.debug("-----远程地址的文件被拉取到:[{}]------------", scriptDirPath);
                 log.debug("-----执行命令初始化完成，命令为：[{}]------------", command);
@@ -73,7 +73,7 @@ public class CommandAndScriptProcessingMachine implements ProcessingMachine {
             processingNodeChain.doProcessing(scriptDto, processingNodeChain);
         } catch (Exception e) {
             log.error("{}", ExecutorLogUtil.getMessage(e));
-            throw new ExecutorException(e);
+            throw new ExecutorException(ExecutorLogUtil.getMessage(e));
         }
     }