info openSession count before engine shutdown because life time too long

apache · Nov 7, 2022 · ae6e12a · ae6e12a
1 parent c0ecb4b
commit ae6e12a
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...yuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala b/...yuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala
@@ -102,7 +102,10 @@ case class SparkSQLEngine(spark: SparkSession) extends Serverable("SparkSQLEngin
             frontendServices.flatMap(_.discoveryService).foreach(_.stop())
           }
 
-          if (backendService.sessionManager.getOpenSessionCount <= 0) {
+          val openSessionCount = backendService.sessionManager.getOpenSessionCount
+          if (openSessionCount > 0) {
+            info(s"${openSessionCount} connection(s) are active, delay shutdown")
+          } else {
             info(s"Spark engine has been running for more than $maxLifetime ms" +
               s" and no open session now, terminating")
             stop()