You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by xx...@apache.org on 2022/12/13 10:25:31 UTC
[kylin] 24/25: fix SparderInitSQLConfTest
This is an automated email from the ASF dual-hosted git repository.
xxyu pushed a commit to branch kylin5
in repository https://gitbox.apache.org/repos/asf/kylin.git
commit 8b571760c1d933a6798713a2ca9fa244b43d973a
Author: sibing.zhang <19...@qq.com>
AuthorDate: Fri Dec 9 11:18:49 2022 +0800
fix SparderInitSQLConfTest
---
.../apache/kylin/query/engine/SparderInitSQLConfTest.java | 13 ++++++++-----
1 file changed, 8 insertions(+), 5 deletions(-)
diff --git a/src/kylin-it/src/test/java/org/apache/kylin/query/engine/SparderInitSQLConfTest.java b/src/kylin-it/src/test/java/org/apache/kylin/query/engine/SparderInitSQLConfTest.java
index bc63a0bccb..b78c40c755 100644
--- a/src/kylin-it/src/test/java/org/apache/kylin/query/engine/SparderInitSQLConfTest.java
+++ b/src/kylin-it/src/test/java/org/apache/kylin/query/engine/SparderInitSQLConfTest.java
@@ -18,7 +18,6 @@
package org.apache.kylin.query.engine;
-
import org.apache.kylin.common.util.NLocalFileMetadataTestCase;
import org.apache.kylin.common.util.RandomUtil;
import org.apache.kylin.common.util.TempMetadataBuilder;
@@ -34,14 +33,18 @@ import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
+import net.jcip.annotations.NotThreadSafe;
+
+@NotThreadSafe
public class SparderInitSQLConfTest extends NLocalFileMetadataTestCase {
@BeforeClass
- public static void beforeClass() throws Exception {
-
- try (SparkSession sparkSession = SparderEnv.getSparkSession()) {
- // do nothing
+ public static void beforeClass() {
+ if (SparderEnv.isSparkAvailable()) {
+ SparderEnv.getSparkSession().close();
}
+ SparkSession.clearActiveSession();
+ SparkSession.clearDefaultSession();
}
@Before