Added an after block to reset spark.broadcast.factory

2013-10-17 22:44:04 -07:00 · 2013-10-17 22:44:04 -07:00 · 8612641362
parent 90ab55fd37
commit 8612641362
1 changed files with 4 additions and 0 deletions
--- a/core/src/test/scala/org/apache/spark/BroadcastSuite.scala
+++ b/core/src/test/scala/org/apache/spark/BroadcastSuite.scala
@ -21,6 +21,10 @@ import org.scalatest.FunSuite

 class BroadcastSuite extends FunSuite with LocalSparkContext {

+  after {
+    System.clearProperty("spark.broadcast.factory")
+  }
+
  test("Using HttpBroadcast locally") {
    System.setProperty("spark.broadcast.factory", "org.apache.spark.broadcast.HttpBroadcastFactory")
    sc = new SparkContext("local", "test")