save

apache · Jan 7, 2023 · 42cafd2 · 42cafd2
1 parent 11c6099
commit 42cafd2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
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
@@ -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
@@ -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)
     }
   }