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 <[email protected]>
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 <[email protected]>
Signed-off-by: ulysses-you <[email protected]>
---
.../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()
