diff options
| author | Shixiong Zhu <shixiong@databricks.com> | 2015-11-12 14:52:03 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-11-12 14:52:03 -0800 |
| commit | f0d3b58d91f43697397cdd7a7e7f38cbb7daaa31 (patch) | |
| tree | 3f7f903c243ad76a233bb636a88015e4d1c7dee4 /streaming | |
| parent | 767d288b6b33a79d99324b70c2ac079fcf484a50 (diff) | |
| download | spark-f0d3b58d91f43697397cdd7a7e7f38cbb7daaa31.tar.gz spark-f0d3b58d91f43697397cdd7a7e7f38cbb7daaa31.tar.bz2 spark-f0d3b58d91f43697397cdd7a7e7f38cbb7daaa31.zip | |
[SPARK-11290][STREAMING][TEST-MAVEN] Fix the test for maven build
Should not create SparkContext in the constructor of `TrackStateRDDSuite`. This is a follow up PR for #9256 to fix the test for maven build.
Author: Shixiong Zhu <shixiong@databricks.com>
Closes #9668 from zsxwing/hotfix.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/test/scala/org/apache/spark/streaming/rdd/TrackStateRDDSuite.scala | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/rdd/TrackStateRDDSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/rdd/TrackStateRDDSuite.scala index fc5f26607e..f396b76e8d 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/rdd/TrackStateRDDSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/rdd/TrackStateRDDSuite.scala @@ -28,11 +28,17 @@ import org.apache.spark.{HashPartitioner, SparkConf, SparkContext, SparkFunSuite class TrackStateRDDSuite extends SparkFunSuite with BeforeAndAfterAll { - private var sc = new SparkContext( - new SparkConf().setMaster("local").setAppName("TrackStateRDDSuite")) + private var sc: SparkContext = null + + override def beforeAll(): Unit = { + sc = new SparkContext( + new SparkConf().setMaster("local").setAppName("TrackStateRDDSuite")) + } override def afterAll(): Unit = { - sc.stop() + if (sc != null) { + sc.stop() + } } test("creation from pair RDD") { |