debug

apache · Jan 7, 2024 · fa2fe08 · fa2fe08
1 parent cb8501e
commit fa2fe08
Showing 1 changed file with 6 additions and 0 deletions.
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
@@ -177,6 +177,8 @@ case class SparkSQLEngine(spark: SparkSession) extends Serverable("SparkSQLEngin
             frontendServices.flatMap(_.discoveryService).foreach(_.stop())
           }
 
+          info(s"graceful period $gracefulPeriod," +
+            s" ${backendService.sessionManager.operationManager.allOperations()}")
           if (backendService.sessionManager.getOpenSessionCount <= 0) {
             info(s"Spark engine has been running for more than $maxLifetime ms" +
               s" and no open session now, terminating.")
@@ -197,6 +199,10 @@ case class SparkSQLEngine(spark: SparkSession) extends Serverable("SparkSQLEngin
                   case e: Throwable =>
                     error(s"Error closing session ${session.handle.identifier}", e)
                 }
+              } else {
+                backendService.sessionManager.operationManager.allOperations()
+                  .filter(_.getSession == session)
+                  .foreach(op => warn(s"Remaining operation: $op"))
               }
             }
           }