You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kyuubi.apache.org by ul...@apache.org on 2022/03/28 02:03:14 UTC
[incubator-kyuubi] branch master updated: [KYUUBI #2231] Close action and default sparksession before `createSpark`.
This is an automated email from the ASF dual-hosted git repository.
ulyssesyou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-kyuubi.git
The following commit(s) were added to refs/heads/master by this push:
new b18be38 [KYUUBI #2231] Close action and default sparksession before `createSpark`.
b18be38 is described below
commit b18be382e8ce83fe7439e1b451461a3d858198f1
Author: wforget <64...@qq.com>
AuthorDate: Mon Mar 28 10:02:58 2022 +0800
[KYUUBI #2231] Close action and default sparksession before `createSpark`.
### _Why are the changes needed?_
close #2231
### _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 #2232 from wForget/KYUUBI-2231.
Closes #2231
96328cf7 [wforget] [KYUUBI-2231] Close action and default sparksession before `createSpark`.
Authored-by: wforget <64...@qq.com>
Signed-off-by: ulysses-you <ul...@apache.org>
---
.../test/scala/org/apache/kyuubi/engine/spark/WithSparkSQLEngine.scala | 2 ++
1 file changed, 2 insertions(+)
diff --git a/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/WithSparkSQLEngine.scala b/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/WithSparkSQLEngine.scala
index 88e33d5..629a837 100644
--- a/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/WithSparkSQLEngine.scala
+++ b/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/kyuubi/engine/spark/WithSparkSQLEngine.scala
@@ -63,6 +63,8 @@ trait WithSparkSQLEngine extends KyuubiFunSuite {
System.setProperty(k, v)
}
+ SparkSession.getActiveSession.foreach(_.close())
+ SparkSession.getDefaultSession.foreach(_.close())
SparkSession.clearActiveSession()
SparkSession.clearDefaultSession()
SparkSQLEngine.setupConf()