diff --git a/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/AbstractOperation.scala b/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/AbstractOperation.scala index 9b6d73d6c78..ad70802b4ca 100644 --- a/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/AbstractOperation.scala +++ b/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/AbstractOperation.scala @@ -174,6 +174,7 @@ abstract class AbstractOperation(opType: OperationType, session: Session) override def getHandle: OperationHandle = handle override def getStatus: OperationStatus = { + lastAccessTime = System.currentTimeMillis() OperationStatus( state, createTime, diff --git a/kyuubi-common/src/main/scala/org/apache/kyuubi/session/AbstractSession.scala b/kyuubi-common/src/main/scala/org/apache/kyuubi/session/AbstractSession.scala index 4af63ddfddc..e29afdc1afb 100644 --- a/kyuubi-common/src/main/scala/org/apache/kyuubi/session/AbstractSession.scala +++ b/kyuubi-common/src/main/scala/org/apache/kyuubi/session/AbstractSession.scala @@ -90,8 +90,8 @@ abstract class AbstractSession( protected def runOperation(operation: Operation): OperationHandle = { try { val opHandle = operation.getHandle - operation.run() opHandleSet.add(opHandle) + operation.run() opHandle } catch { case e: KyuubiSQLException =>