Skip to content

Commit fde98bb

Browse files
committed
Create separate spark session for the test
1 parent cb2d16c commit fde98bb

1 file changed

Lines changed: 9 additions & 3 deletions

File tree

hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestGenericRecordAndRowConsistency.scala

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -45,12 +45,18 @@ class TestGenericRecordAndRowConsistency extends HoodieClientTestBase {
4545
@BeforeEach override def setUp(): Unit = {
4646
setTableName("hoodie_type_consistency_tbl")
4747
initPath()
48-
initSparkContexts()
49-
spark = sqlContext.sparkSession
48+
spark = SparkSession.builder
49+
.appName("Hoodie RecordAndRowConsistency Test")
50+
.master("local[2]")
51+
.config("spark.serializer", "org.apache.spark.serializer.KryoSerializer")
52+
.getOrCreate
5053
}
5154

5255
@AfterEach override def tearDown(): Unit = {
53-
cleanupSparkContexts()
56+
if (spark != null) {
57+
spark.stop()
58+
spark = null
59+
}
5460
}
5561

5662
@Test

0 commit comments

Comments
 (0)