[bugfix] close method moved to finally (#5165)

apache · Sep 4, 2024 · b6e929a · b6e929a
1 parent 9560905
commit b6e929a
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/...e-engineconn/src/main/scala/org/apache/linkis/engineconn/once/executor/OnceExecutor.scala b/...e-engineconn/src/main/scala/org/apache/linkis/engineconn/once/executor/OnceExecutor.scala
@@ -186,8 +186,10 @@ trait ManageableOnceExecutor extends AccessibleExecutor with OnceExecutor with R
     logger.error(msg)
     Utils.tryFinally {
       this.ensureAvailable(transition(NodeStatus.Failed))
+    } {
       close()
-    }(stopOnceExecutor(msg))
+      stopOnceExecutor(msg)
+    }
     true
   }
 
@@ -197,8 +199,10 @@ trait ManageableOnceExecutor extends AccessibleExecutor with OnceExecutor with R
     logger.warn(msg)
     Utils.tryFinally {
       this.ensureAvailable(transition(NodeStatus.Success))
+    } {
       close()
-    }(stopOnceExecutor(msg))
+      stopOnceExecutor(msg)
+    }
     true
   }