[MINOR] Fix confusing variable name

apache · Mar 11, 2024 · 83ed8d2 · 83ed8d2
1 parent 9fd392b
commit 83ed8d2
Showing 1 changed file with 2 additions 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,8 @@ class FlinkSQLSessionManager(engineContext: DefaultContext)
 
   override def closeSession(sessionHandle: SessionHandle): Unit = {
     try {
-      val fSession = super.getSessionOption(sessionHandle)
-      fSession.foreach(s =>
+      val session = super.getSessionOption(sessionHandle)
+      session.foreach(s =>
         sessionManager.closeSession(s.asInstanceOf[FlinkSessionImpl].fSession.getSessionHandle))
       super.closeSession(sessionHandle)
     } catch {