diff options
| -rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/client/AppClient.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/deploy/client/AppClient.scala b/core/src/main/scala/org/apache/spark/deploy/client/AppClient.scala index 737ba09117..4779c75137 100644 --- a/core/src/main/scala/org/apache/spark/deploy/client/AppClient.scala +++ b/core/src/main/scala/org/apache/spark/deploy/client/AppClient.scala @@ -180,7 +180,7 @@ private[spark] class AppClient( if (actor != null) { try { val timeout = AkkaUtils.askTimeout - val future = actor.ask(StopClient)(timeout) + val future = actor.ask(StopAppClient)(timeout) Await.result(future, timeout) } catch { case e: TimeoutException => |