Skip to content

Commit d68b3af

Browse files
authored
FilterPushdownBenchmark SparkSession should be lazy (apache-spark-on-k8s#394)
1 parent c4f20b9 commit d68b3af

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

sql/core/src/test/java/test/org/apache/spark/sql/JavaDataFrameSuite.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -45,19 +45,19 @@
4545
import static org.apache.spark.sql.types.DataTypes.*;
4646

4747
public class JavaDataFrameSuite {
48-
private static TestSparkSession spark;
49-
private static JavaSparkContext jsc;
48+
private transient TestSparkSession spark;
49+
private transient JavaSparkContext jsc;
5050

51-
@BeforeClass
52-
public static void setUp() {
51+
@Before
52+
public void setUp() {
5353
// Trigger static initializer of TestData
5454
spark = new TestSparkSession();
5555
jsc = new JavaSparkContext(spark.sparkContext());
5656
spark.loadTestData();
5757
}
5858

59-
@AfterClass
60-
public static void tearDown() {
59+
@After
60+
public void tearDown() {
6161
spark.stop();
6262
spark = null;
6363
}

sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/FilterPushdownBenchmark.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ class FilterPushdownBenchmark extends SparkFunSuite with BenchmarkBeforeAndAfter
5555
private val mid = numRows / 2
5656
private val blockSize = 1048576
5757

58-
private val spark = SparkSession.builder().config(conf).getOrCreate()
58+
private lazy val spark = SparkSession.builder().config(conf).getOrCreate()
5959

6060
private var out: OutputStream = _
6161

0 commit comments

Comments
 (0)