diff --git a/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java b/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java index ba3e682..d41009e 100644 --- a/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java +++ b/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java @@ -201,7 +201,6 @@ public class CommandExecutor { ); } - // 日志操作,如果需要显示回传,需要将日志发送回相应的 collectCommandLogAndRepeat( streamKey, @@ -216,7 +215,6 @@ public class CommandExecutor { } - } }; } diff --git a/agent/src/main/java/io/wdd/agent/executor/thread/CommandExecLogCache.java b/agent/src/main/java/io/wdd/agent/executor/thread/CommandExecLogCache.java index 9ef34ee..109a7ac 100644 --- a/agent/src/main/java/io/wdd/agent/executor/thread/CommandExecLogCache.java +++ b/agent/src/main/java/io/wdd/agent/executor/thread/CommandExecLogCache.java @@ -37,6 +37,8 @@ public class CommandExecLogCache { */ public void cacheLog(String streamKey, Process process) { + Assert.notNull(process,"命令执行为空!"); + ArrayList commandCachedLog = new ArrayList<>(128); String execCommandString = String.format(