comment

apache · Mar 11, 2024 · 51bc0c5 · 51bc0c5
1 parent 83ed8d2
commit 51bc0c5
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala b/...engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala
@@ -83,8 +83,7 @@ class FlinkSQLSessionManager(engineContext: DefaultContext)
 
   override def closeSession(sessionHandle: SessionHandle): Unit = {
     try {
-      val session = super.getSessionOption(sessionHandle)
-      session.foreach(s =>
+      super.getSessionOption(sessionHandle).foreach(s =>
         sessionManager.closeSession(s.asInstanceOf[FlinkSessionImpl].fSession.getSessionHandle))
       super.closeSession(sessionHandle)
     } catch {