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 9c2832c57..a04a7d1bb 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 @@ -152,7 +152,7 @@ object SparkSQLEngine extends Logging { // blocking main thread countDownLatch.await() } catch { - case t: Throwable => + case t: Throwable if currentEngine.isDefined => currentEngine.foreach { engine => val status = engine.engineStatus.copy(diagnostic = s"Error State SparkSQL Engine ${t.getMessage}") @@ -160,6 +160,8 @@ object SparkSQLEngine extends Logging { error(status, t) engine.stop() } + case t: Throwable => + error("Create SparkSQL Engine Failed", t) } finally { if (spark != null) { spark.stop()