[agent][executor]- bug

agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java

@@ -105,6 +105,7 @@ public class CommandExecutor {
             // 开始执行命令操作
             CountDownLatch countDownLatch = new CountDownLatch(1);
 
+            // 开始执行命令操作
             Process process = processBuilder.start();
 
             // 守护进程 对每一条任务的超时时间进行限制，避免卡死
@@ -116,8 +117,6 @@ public class CommandExecutor {
                 commandExecWaitTimeout = durationTaskMaxWaitSeconds;
             }
 
-
-
             // 2023年2月23日  同时执行log日志部分移动至此部分处理
             AgentCommonThreadPool.pool.submit(
                     DaemonCommandProcessAndCollectLog(
@@ -137,7 +136,6 @@ public class CommandExecutor {
 
                 // 命令执行完成， countDownLatch计数
                 countDownLatch.countDown();
-
                 // 设置 命令执行退出返回值
                 processResult = process.exitValue();
 

agent/src/main/java/io/wdd/agent/executor/thread/CommandExecLogCache.java

@@ -3,6 +3,7 @@ package io.wdd.agent.executor.thread;
 
 import io.wdd.common.utils.TimeUtils;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
 import org.springframework.stereotype.Component;
 import org.springframework.util.Assert;
 
@@ -37,7 +38,15 @@ public class CommandExecLogCache {
      */
     public void cacheLog(String streamKey, Process process) {
 
-        Assert.notNull(process,"命令执行为空！");
+        log.debug(
+                "开始缓存命令执行日志！ process is {}",
+                process
+        );
+
+        if (ObjectUtils.isEmpty(process)) {
+            log.error("process is null ! cache log error !");
+            return;
+        }
 
         ArrayList<String> commandCachedLog = new ArrayList<>(128);