From 315e07f7b977aefd3309d8f322acd8ee5fd93714 Mon Sep 17 00:00:00 2001
From: zeaslity <zeaslity@qq.com>
Date: Sun, 26 Feb 2023 11:56:09 +0800
Subject: [PATCH] [agent][executor]- bug - 9

---
 .../agent/executor/thread/CommandExecLogCache.java   | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 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 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);