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()

Reply via email to