From b88cb01300822a295cf001416084f119b42aa639 Mon Sep 17 00:00:00 2001 From: zeaslity Date: Sun, 26 Feb 2023 15:51:10 +0800 Subject: [PATCH] [agent][executor]- bug - 14 --- .../io/wdd/agent/executor/CommandExecutor.java | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) 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 7e3bb50..d1c0e8b 100644 --- a/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java +++ b/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java @@ -151,6 +151,13 @@ public class CommandExecutor { private void DaemonCommandProcessAndCollectLog(Process process, int commandExecWaitTimeout, CountDownLatch countDownLatch, boolean needResultReplay, String streamKey, OctopusMessage octopusMessage) { + // 缓存 命令处理日志 + // 如果是特别简单的命令,必须要放在此处才可以,否则会导致 无法收集 + commandExecLogCache.cacheLog( + streamKey, + process + ); + boolean commandExecComplete = false; try { @@ -175,13 +182,6 @@ public class CommandExecutor { System.out.println("process isAlive = " + process.isAlive()); - // 缓存 命令处理日志 - // 如果是特别简单的命令,必须要放在此处才可以,否则会导致 无法收集 - commandExecLogCache.cacheLog( - streamKey, - process - ); - // 任务提前执行结束,或者超过了最长等待时间 // 判断命令是否正确处理完成 if (!commandExecComplete) { @@ -204,7 +204,6 @@ public class CommandExecutor { .info() ); } - } // 打印一下 debug