From 9199775d41671b951ff76c599fe24d04b6633f5c Mon Sep 17 00:00:00 2001 From: Matei Zaharia Date: Wed, 12 Sep 2012 14:50:37 -0700 Subject: Wait for Akka to really shut down in SparkEnv.stop() --- core/src/main/scala/spark/SparkEnv.scala | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'core') diff --git a/core/src/main/scala/spark/SparkEnv.scala b/core/src/main/scala/spark/SparkEnv.scala index a95d1bc8ea..b9efdbde64 100644 --- a/core/src/main/scala/spark/SparkEnv.scala +++ b/core/src/main/scala/spark/SparkEnv.scala @@ -1,6 +1,8 @@ package spark import akka.actor.ActorSystem +import akka.actor.ActorSystemImpl +import akka.remote.RemoteActorRefProvider import spark.broadcast.BroadcastManager import spark.storage.BlockManager @@ -39,6 +41,8 @@ class SparkEnv ( blockManager.master.stop() actorSystem.shutdown() actorSystem.awaitTermination() + // Akka's awaitTermination doesn't actually wait until the port is unbound, so sleep a bit + Thread.sleep(100) } } -- cgit v1.2.3