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 072f762..03b41fe 100644 --- a/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java +++ b/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java @@ -184,6 +184,11 @@ public class CommandExecutor { System.out.println("process isAlive = " + process.isAlive()); + // 缓存 命令处理日志 + commandExecLogCache.cacheLog( + streamKey, + process + ); // 任务提前执行结束,或者超过了最长等待时间 // 判断命令是否正确处理完成 @@ -216,12 +221,6 @@ public class CommandExecutor { } } - // 缓存 命令处理日志 - commandExecLogCache.cacheLog( - streamKey, - process - ); - // 日志操作,如果需要显示回传,需要将日志发送回相应的 /*collectCommandLogAndRepeat( streamKey,