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 264c319..4d4bf02 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 @@ -95,15 +95,11 @@ public class CommandExecLogCache { TimeUtils.currentTimeString() ); - String execResultString = String.format( - "execution result is => [ %s ]", - process.exitValue() - ); + // add the command commandCachedLog.add(execCommandString); commandCachedLog.add(execTimeString); - commandCachedLog.add(execResultString); commandCachedLog.add("--------------- command result are as below --------------------"); commandCachedLog.add(""); @@ -121,7 +117,6 @@ public class CommandExecLogCache { bufferedReader ); - // !! 此处会阻塞 // 阻塞读取命令执行日志的输出流 bufferedReader @@ -130,6 +125,13 @@ public class CommandExecLogCache { commandCachedLog::add ); + String execResultString = String.format( + "execution result is => [ %s ]", + process.exitValue() + ); + commandCachedLog.add(execResultString); + + log.debug( "命令代码 [ {} ] 的执行日志内容为 {} ", streamKey,