You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@livy.apache.org by gg...@apache.org on 2024/06/25 14:11:08 UTC

(incubator-livy) branch master updated: [LIVY-992][SERVER] In livy logs, user is not able to differentiate between interactive session and batch session (#435)

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 <rs...@gmail.com>
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 <ra...@cloudera.com>
---
 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}")
       }
     }
   }