debug

turboFei · Jan 7, 2024 · fe46552 · fe46552
1 parent cb8501e
commit fe46552
Showing 1 changed file with 8 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,9 @@ case class SparkSQLEngine(spark: SparkSession) extends Serverable("SparkSQLEngin
             frontendServices.flatMap(_.discoveryService).foreach(_.stop())
           }
 
+          // scalastyle:off println
+          println(s"graceful period $gracefulPeriod," +
+            s" ${backendService.sessionManager.operationManager.allOperations().mkString("\t")}")
           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,7 +200,12 @@ 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 => println(s"Remaining operation: $op"))
               }
+              // scalastyle:off println
             }
           }
         }