aboutsummaryrefslogtreecommitdiff
path: root/repl
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 /repl
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 'repl')
-rw-r--r--repl/src/test/scala/spark/repl/ReplSuite.scala2
1 files changed, 2 insertions, 0 deletions
diff --git a/repl/src/test/scala/spark/repl/ReplSuite.scala b/repl/src/test/scala/spark/repl/ReplSuite.scala
index 0b5d439ca4..db78d06d4f 100644
--- a/repl/src/test/scala/spark/repl/ReplSuite.scala
+++ b/repl/src/test/scala/spark/repl/ReplSuite.scala
@@ -30,6 +30,8 @@ class ReplSuite extends FunSuite {
spark.repl.Main.interp = null
if (interp.sparkContext != null)
interp.sparkContext.stop()
+ // To avoid Akka rebinding to the same port, since it doesn't unbind immediately on shutdown
+ System.clearProperty("spark.master.port")
return out.toString
}