aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorMosharaf Chowdhury <mosharaf@cs.berkeley.edu>2013-10-17 22:44:04 -0700
committerMosharaf Chowdhury <mosharaf@cs.berkeley.edu>2013-10-17 22:44:04 -0700
commit8612641362074fe09ced48e1aff70274a4de1d78 (patch)
treea336395ded9f5e9b84e8fac5d90b4ddbfc8c07d0 /core
parent90ab55fd379a89f4bce7d8420599d704093aa3f3 (diff)
downloadspark-8612641362074fe09ced48e1aff70274a4de1d78.tar.gz
spark-8612641362074fe09ced48e1aff70274a4de1d78.tar.bz2
spark-8612641362074fe09ced48e1aff70274a4de1d78.zip
Added an after block to reset spark.broadcast.factory
Diffstat (limited to 'core')
-rw-r--r--core/src/test/scala/org/apache/spark/BroadcastSuite.scala4
1 files changed, 4 insertions, 0 deletions
diff --git a/core/src/test/scala/org/apache/spark/BroadcastSuite.scala b/core/src/test/scala/org/apache/spark/BroadcastSuite.scala
index 6a5d2fa0ff..25ccfb0b04 100644
--- 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")