This is an automated email from the ASF dual-hosted git repository.
ggal pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-livy.git
The following commit(s) were added to refs/heads/master by this push:
new 78ddd595 [LIVY-992][SERVER] In livy logs, user is not able to
differentiate between interactive session and batch session (#435)
78ddd595 is described below
commit 78ddd595953711aeed2a40b76408b58faba971f1
Author: RajshekharMuchandi <[email protected]>
AuthorDate: Tue Jun 25 19:41:02 2024 +0530
[LIVY-992][SERVER] In livy logs, user is not able to differentiate between
interactive session and batch session (#435)
Changed log info to provide session type details
Co-authored-by: Rajshekhar Muchandi <[email protected]>
---
server/src/main/scala/org/apache/livy/sessions/SessionManager.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/server/src/main/scala/org/apache/livy/sessions/SessionManager.scala
b/server/src/main/scala/org/apache/livy/sessions/SessionManager.scala
index 16425964..b81bbc03 100644
--- a/server/src/main/scala/org/apache/livy/sessions/SessionManager.scala
+++ b/server/src/main/scala/org/apache/livy/sessions/SessionManager.scala
@@ -128,7 +128,7 @@ class SessionManager[S <: Session, R <: RecoveryMetadata :
ClassTag](
}
def delete(session: S): Future[Unit] = {
- info(s"Deleting session ${session.id}")
+ info(s"Deleting ${session}")
session.stop().map { case _ =>
try {
sessionStore.remove(sessionType, session.id)
@@ -141,7 +141,7 @@ class SessionManager[S <: Session, R <: RecoveryMetadata :
ClassTag](
error("Exception was thrown during stop session:", e)
throw e
} finally {
- info(s"Deleted session ${session.id}")
+ info(s"Deleted ${session}")
}
}
}
