From 4597e87970521e916364fef71cb955c5a28330d4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=B0=8F=E6=B8=85?=
 <62982788+597365581@users.noreply.github.com>
Date: Sat, 30 Jan 2021 09:53:25 +0800
Subject: [PATCH] Update AbstractCommandExecutor.java

---
 .../server/worker/task/AbstractCommandExecutor.java              | 1 +
 1 file changed, 1 insertion(+)

diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/AbstractCommandExecutor.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/AbstractCommandExecutor.java
index cd57be9181..5b09be85ae 100644
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/AbstractCommandExecutor.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/AbstractCommandExecutor.java
@@ -363,6 +363,7 @@ public abstract class AbstractCommandExecutor {
                 }
             }
         });
+        getOutputLogService.shutdown();
 
         ExecutorService parseProcessOutputExecutorService = ThreadUtils.newDaemonSingleThreadExecutor(threadLoggerInfoName);
         parseProcessOutputExecutorService.submit(new Runnable() {