Added an after block to reset spark.broadcast.factory
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/86126413 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/86126413 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/86126413 Branch: refs/heads/master Commit: 8612641362074fe09ced48e1aff70274a4de1d78 Parents: 90ab55f Author: Mosharaf Chowdhury <mosha...@cs.berkeley.edu> Authored: Thu Oct 17 22:44:04 2013 -0700 Committer: Mosharaf Chowdhury <mosha...@cs.berkeley.edu> Committed: Thu Oct 17 22:44:04 2013 -0700 ---------------------------------------------------------------------- core/src/test/scala/org/apache/spark/BroadcastSuite.scala | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/86126413/core/src/test/scala/org/apache/spark/BroadcastSuite.scala ---------------------------------------------------------------------- diff --git a/core/src/test/scala/org/apache/spark/BroadcastSuite.scala b/core/src/test/scala/org/apache/spark/BroadcastSuite.scala index 6a5d2fa..25ccfb0 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")
