diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala index 00e5abcefcd..ff0d7c2e47f 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala +++ b/externals/kyuubi-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")) } } }