This is an automated email from the ASF dual-hosted git repository.
yao pushed a commit to branch branch-1.5
in repository https://gitbox.apache.org/repos/asf/incubator-kyuubi.git
The following commit(s) were added to refs/heads/branch-1.5 by this push:
new 6f98cc2 [KYUUBI #2063] Fix engine idle timeout lose efficacy for
Flink Engine
6f98cc2 is described below
commit 6f98cc215d1bb93f6e531e8c230da8803ea5fe27
Author: yanghua <[email protected]>
AuthorDate: Wed Mar 9 11:22:58 2022 +0800
[KYUUBI #2063] Fix engine idle timeout lose efficacy for Flink Engine
### _Why are the changes needed?_
### _How was this patch tested?_
- [ ] Add some test cases that check the changes thoroughly including
negative and positive cases if possible
- [ ] Add screenshots for manual tests if appropriate
- [ ] [Run
test](https://kyuubi.apache.org/docs/latest/develop_tools/testing.html#running-tests)
locally before make a pull request
Closes #2064 from yanghua/KYUUBI-2063.
Closes #2063
35ea82cf [yanghua] [KYUUBI #2063] Fix engine idle timeout lose efficacy for
Flink Engine
Authored-by: yanghua <[email protected]>
Signed-off-by: Kent Yao <[email protected]>
(cherry picked from commit dde8381911a01c71f24ebda8888510b0399f3448)
Signed-off-by: Kent Yao <[email protected]>
---
.../org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala | 1 +
1 file changed, 1 insertion(+)
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 a14e4c0..4e4f490 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
@@ -76,6 +76,7 @@ class FlinkSQLSessionManager(engineContext: DefaultContext)
}
override def closeSession(sessionHandle: SessionHandle): Unit = {
+ super.closeSession(sessionHandle)
executor.closeSession(sessionHandle.toString)
}
}
