From 5bb30904492faabcfd215545c3209d003d25082f Mon Sep 17 00:00:00 2001 From: zeaslity Date: Sun, 26 Feb 2023 15:35:23 +0800 Subject: [PATCH] [agent][executor]- bug - 12 --- .../main/java/io/wdd/agent/executor/CommandExecutor.java | 1 - .../io/wdd/agent/executor/thread/CommandExecLogCache.java | 6 ++++-- 2 files changed, 4 insertions(+), 3 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 dce2a3d..a559579 100644 --- a/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java +++ b/agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java @@ -213,7 +213,6 @@ public class CommandExecutor { streamKey, process ); - process.destroyForcibly(); } 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 cbc0353..1ecd01d 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 @@ -146,7 +146,6 @@ public class CommandExecLogCache { commandCachedLog::add ); - log.debug( "命令代码 [ {} ] 的执行日志内容为 {} ", streamKey, @@ -183,10 +182,13 @@ public class CommandExecLogCache { } catch (IOException e) { throw new RuntimeException(e); } finally { + log.debug( + "关闭 [{}]的各种输入流读取器成功 !", + streamKey + ); CommandLogBufferedReaderMap.remove(streamKey); CommandLogInputReaderMap.remove(streamKey); - }