From f7eccfb19f5c602c0713e36c106263028b901807 Mon Sep 17 00:00:00 2001 From: Rajshekhar Muchandi Date: Mon, 20 Nov 2023 11:36:49 +0530 Subject: [PATCH] [LIVY-993][SERVER] In Livy logs, user cannot find out on whether session is deleted due to session timed out or session state retained value expired Changed log info to elaborate more on session deletion --- .../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 164259642..a3b45a97e 100644 --- a/server/src/main/scala/org/apache/livy/sessions/SessionManager.scala +++ b/server/src/main/scala/org/apache/livy/sessions/SessionManager.scala @@ -193,9 +193,9 @@ class SessionManager[S <: Session, R <: RecoveryMetadata : ClassTag]( Future.sequence(all().filter(expired).map { s => s.state match { case st: FinishedSessionState => - info(s"Deleting $s because it finished before ${sessionStateRetainedInSec / 1e9} secs.") + info(s"Deleting $s because session state retained time is expired in ${sessionStateRetainedInSec / 1e9} secs.") case _ => - info(s"Deleting $s because it was inactive or the time to leave the period is over.") + info(s"Deleting $s because either session timed out or ttl expired.") } delete(s) })