From 550f5984cddcbb1002aa9b73d3d9c5cc50cbf957 Mon Sep 17 00:00:00 2001 From: peacewong Date: Sat, 19 Mar 2022 21:23:53 +0800 Subject: [PATCH] add close to shutdown --- .../acessible/executor/service/DefaultAccessibleService.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultAccessibleService.scala b/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultAccessibleService.scala index 4f51c2acdb..ebd701dde2 100644 --- a/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultAccessibleService.scala +++ b/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/service/DefaultAccessibleService.scala @@ -80,6 +80,7 @@ class DefaultAccessibleService extends AccessibleService with Logging { var executor: Executor = ExecutorManager.getInstance.getReportExecutor if (null != executor) { Utils.tryAndWarn{ + executor.close() executor.tryShutdown() } warn(s"Engine : ${Sender.getThisInstance} with state has stopped successfully.")