From f2be1dfb5c92333552a85f8d3d7b6b4939f10a22 Mon Sep 17 00:00:00 2001 From: zeaslity Date: Sun, 26 Feb 2023 11:58:48 +0800 Subject: [PATCH] [agent][executor]- bug - 9 --- .../agent/executor/thread/CommandExecLogCache.java | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) 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,