This is an automated email from the ASF dual-hosted git repository.
nicholasjiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 2c3c547bc [hotfix] Fix CallStatementParserTest stop and clear spark
active session (#1907)
2c3c547bc is described below
commit 2c3c547bca9f883ac4ff97e94e972e28edf5822c
Author: Nicholas Jiang <[email protected]>
AuthorDate: Mon Aug 28 20:09:07 2023 +0800
[hotfix] Fix CallStatementParserTest stop and clear spark active session
(#1907)
---
.../org/apache/paimon/spark/extensions/CallStatementParserTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/extensions/CallStatementParserTest.java
b/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/extensions/CallStatementParserTest.java
index ae7c0e067..1ecdc89d8 100644
---
a/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/extensions/CallStatementParserTest.java
+++
b/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/extensions/CallStatementParserTest.java
@@ -51,6 +51,8 @@ public class CallStatementParserTest {
@BeforeEach
public void startSparkSession() {
+ // Stops and clears active session to avoid loading previous
non-stopped session.
+
SparkSession.getActiveSession().orElse(SparkSession::getDefaultSession).get().stop();
SparkSession.clearActiveSession();
spark =
SparkSession.builder()