diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SessionEvent.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SessionEvent.scala index 8d87b1cd940..6f4ee78d600 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SessionEvent.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/events/SessionEvent.scala @@ -39,6 +39,7 @@ import org.apache.kyuubi.events.KyuubiEvent */ case class SessionEvent( @KVIndexParam sessionId: String, + name: String, engineId: String, username: String, ip: String, @@ -67,6 +68,7 @@ object SessionEvent { def apply(session: SparkSessionImpl): SessionEvent = { new SessionEvent( session.handle.identifier.toString, + session.name.getOrElse(""), KyuubiSparkUtil.engineId, session.user, session.ipAddress, diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/ui/EnginePage.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/ui/EnginePage.scala index 7ff3453cdf7..94316c91b86 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/ui/EnginePage.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/ui/EnginePage.scala @@ -250,6 +250,7 @@ case class EnginePage(parent: EngineTab) extends WebUIPage("") { ("Client IP", true, None), ("Server IP", true, None), ("Session ID", true, None), + ("Session Name", true, None), ("Start Time", true, None), ("Finish Time", true, None), ("Duration", true, None), @@ -275,6 +276,7 @@ case class EnginePage(parent: EngineTab) extends WebUIPage("") {