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 ae2c7d6..264c319 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 @@ -143,13 +143,17 @@ public class CommandExecLogCache { */ public void StopExecLogBufferedReader(String streamKey) { + BufferedReader bufferedReader = CommandLogReaderMap.get(streamKey); + + log.debug( + "开始关停任务 [ {} ]对应的日志读取BufferedReader {}", + streamKey, + bufferedReader + ); + if (ObjectUtils.isNotEmpty(bufferedReader)) { try { - - log.debug("开始关停任务 [ {} ]对应的日志读取后端", - streamKey); - bufferedReader.close(); } catch (IOException e) { throw new RuntimeException(e);