aboutsummaryrefslogtreecommitdiff
path: root/bagel
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2012-10-07 00:17:59 -0700
committerMatei Zaharia <matei@eecs.berkeley.edu>2012-10-07 00:17:59 -0700
commiteca570f66a3d93bc1745a9fcf8410ad0a9db3e64 (patch)
tree52e8eb4addd243c8ecd30c1297c50ee54c4906ee /bagel
parentb2fc3dd902d12ab936cd0f51431868010e521e28 (diff)
downloadspark-eca570f66a3d93bc1745a9fcf8410ad0a9db3e64.tar.gz
spark-eca570f66a3d93bc1745a9fcf8410ad0a9db3e64.tar.bz2
spark-eca570f66a3d93bc1745a9fcf8410ad0a9db3e64.zip
Removed the need to sleep in tests due to waiting for Akka to shut down
Diffstat (limited to 'bagel')
-rw-r--r--bagel/src/test/scala/bagel/BagelSuite.scala2
1 files changed, 2 insertions, 0 deletions
diff --git a/bagel/src/test/scala/bagel/BagelSuite.scala b/bagel/src/test/scala/bagel/BagelSuite.scala
index 3da7152a09..ca59f46843 100644
--- a/bagel/src/test/scala/bagel/BagelSuite.scala
+++ b/bagel/src/test/scala/bagel/BagelSuite.scala
@@ -22,6 +22,8 @@ class BagelSuite extends FunSuite with Assertions 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("halting by voting") {