This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/master by this push:
new b6e929adc [bugfix] close method moved to finally (#5165)
b6e929adc is described below
commit b6e929adc7d97f3fa74b6707a7900a74a0660fb4
Author: 人生有如两个橘子 <[email protected]>
AuthorDate: Wed Sep 4 20:44:45 2024 +0800
[bugfix] close method moved to finally (#5165)
---
.../org/apache/linkis/engineconn/once/executor/OnceExecutor.scala | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git
a/linkis-computation-governance/linkis-engineconn/linkis-clustered-engineconn/linkis-once-engineconn/src/main/scala/org/apache/linkis/engineconn/once/executor/OnceExecutor.scala
b/linkis-computation-governance/linkis-engineconn/linkis-clustered-engineconn/linkis-once-engineconn/src/main/scala/org/apache/linkis/engineconn/once/executor/OnceExecutor.scala
index dee4a885d..30faaa829 100644
---
a/linkis-computation-governance/linkis-engineconn/linkis-clustered-engineconn/linkis-once-engineconn/src/main/scala/org/apache/linkis/engineconn/once/executor/OnceExecutor.scala
+++
b/linkis-computation-governance/linkis-engineconn/linkis-clustered-engineconn/linkis-once-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
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
