diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/BatchJobSubmission.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/BatchJobSubmission.scala index 10cd35df4ab..1485f457fa8 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/BatchJobSubmission.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/BatchJobSubmission.scala @@ -158,7 +158,7 @@ class BatchJobSubmission( session.getSessionEvent.foreach(_.engineId = ai.id) } if (newState == RUNNING) { - session.onEngineOpened(_appSubmissionTime) + session.onEngineOpened() } } } diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSessionImpl.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSessionImpl.scala index 31093f2ff3f..dcf7fa116b5 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSessionImpl.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/session/KyuubiBatchSessionImpl.scala @@ -159,9 +159,9 @@ class KyuubiBatchSessionImpl( sessionEvent.totalOperations += 1 } - private[kyuubi] def onEngineOpened(openedTime: Long): Unit = { + private[kyuubi] def onEngineOpened(): Unit = { if (sessionEvent.openedTime <= 0) { - sessionEvent.openedTime = openedTime + sessionEvent.openedTime = batchJobSubmissionOp.appSubmissionTime EventBus.post(sessionEvent) } }