diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-09-24 15:39:58 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-09-24 15:39:58 -0700 |
| commit | 6eeb379cf86b25975456369cc3de50a41a648b69 (patch) | |
| tree | 5e8de3937c6850e1b56324a310e41bdc8bece890 /core/src/main | |
| parent | 35cc9f13e96c9b19a032b54e69160eea47589fc9 (diff) | |
| download | spark-6eeb379cf86b25975456369cc3de50a41a648b69.tar.gz spark-6eeb379cf86b25975456369cc3de50a41a648b69.tar.bz2 spark-6eeb379cf86b25975456369cc3de50a41a648b69.zip | |
Fix some test issues
Diffstat (limited to 'core/src/main')
| -rw-r--r-- | core/src/main/scala/spark/SparkEnv.scala | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/core/src/main/scala/spark/SparkEnv.scala b/core/src/main/scala/spark/SparkEnv.scala index 7473b40aa3..6ffae8e85f 100644 --- a/core/src/main/scala/spark/SparkEnv.scala +++ b/core/src/main/scala/spark/SparkEnv.scala @@ -40,6 +40,8 @@ class SparkEnv ( blockManager.stop() blockManager.master.stop() actorSystem.shutdown() + // Akka's awaitTermination doesn't actually wait until the port is unbound, so sleep a bit + Thread.sleep(100) actorSystem.awaitTermination() // Akka's awaitTermination doesn't actually wait until the port is unbound, so sleep a bit Thread.sleep(100) |