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 a4603022f14..8d7b0ab6dca 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 @@ -31,7 +31,7 @@ import org.apache.kyuubi.events.{EventLogging, KyuubiEvent, KyuubiSessionEvent} import org.apache.kyuubi.ha.client.ZooKeeperClientProvider._ import org.apache.kyuubi.metrics.MetricsConstants._ import org.apache.kyuubi.metrics.MetricsSystem -import org.apache.kyuubi.operation.{Operation, OperationHandle} +import org.apache.kyuubi.operation.{Operation, OperationHandle, OperationState} import org.apache.kyuubi.operation.log.OperationLog import org.apache.kyuubi.service.authentication.EngineSecurityAccessor @@ -145,7 +145,7 @@ class KyuubiSessionImpl( } override def close(): Unit = { - if (!launchEngineOp.isTimedOut) { + if (!OperationState.isTerminal(launchEngineOp.getStatus.state)) { closeOperation(launchEngineOp.getHandle) } super.close()