assert engine

apache · Nov 30, 2021 · dc07b38 · dc07b38
1 parent 6df54eb
commit dc07b38
Showing 1 changed file with 2 additions and 4 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
@@ -55,10 +55,8 @@ case class SparkSQLEngine(
     // Start engine self-terminating checker after all services are ready and it can be reached by
     // all servers in engine spaces.
     backendService.sessionManager.startTerminatingChecker(() => {
-      currentEngine match {
-        case Some(engine) =>
-          engine.stop()
-      }
+      assert(currentEngine.isDefined)
+      currentEngine.get.stop()
     })
   }