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 55b0955e63e..3311f289338 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 @@ -126,7 +126,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 {