aboutsummaryrefslogtreecommitdiff
path: root/core/src/test/scala/spark/BroadcastSuite.scala
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/test/scala/spark/BroadcastSuite.scala')
-rw-r--r--core/src/test/scala/spark/BroadcastSuite.scala2
1 files changed, 2 insertions, 0 deletions
diff --git a/core/src/test/scala/spark/BroadcastSuite.scala b/core/src/test/scala/spark/BroadcastSuite.scala
index 0738a2725b..2d3302f0aa 100644
--- a/core/src/test/scala/spark/BroadcastSuite.scala
+++ b/core/src/test/scala/spark/BroadcastSuite.scala
@@ -12,6 +12,8 @@ class BroadcastSuite extends FunSuite with BeforeAndAfter {
sc.stop()
sc = null
}
+ // To avoid Akka rebinding to the same port, since it doesn't unbind immediately on shutdown
+ System.clearProperty("spark.master.port")
}
test("basic broadcast") {