From 51bc0c55d9434f593054e8675e0015a59243e8da Mon Sep 17 00:00:00 2001
From: wforget <643348094@qq.com>
Date: Mon, 11 Mar 2024 15:41:04 +0800
Subject: [PATCH] comment

---
 .../kyuubi/engine/flink/session/FlinkSQLSessionManager.scala   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala b/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala
index e2557abf513..d1f601ba852 100644
--- a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala
+++ b/externals/kyuubi-flink-sql-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 {