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.")