From 83ed8d2a7adabd12a0f67d6e6993700acad98957 Mon Sep 17 00:00:00 2001 From: wforget <643348094@qq.com> Date: Mon, 11 Mar 2024 15:25:43 +0800 Subject: [PATCH] [MINOR] Fix confusing variable name --- .../kyuubi/engine/flink/session/FlinkSQLSessionManager.scala | 4 ++-- 1 file changed, 2 insertions(+), 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 1bb82a0ef6d..e2557abf513 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,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 {