diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala index 15a9ea11175..bf0fc6b73da 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiSessionImpl.scala @@ -139,7 +139,9 @@ class KyuubiSessionImpl( } override def close(): Unit = { - closeOperation(launchEngineOp.getHandle) + if (!launchEngineOp.isTimedOut) { + closeOperation(launchEngineOp.getHandle) + } super.close() sessionManager.credentialsManager.removeSessionCredentialsEpoch(handle.identifier.toString) try {