Skip to content

Commit 78a2c0a

Browse files
committed
[SPARK-6980] Using RpcTimeout.awaitResult for future in AppClient now
1 parent 97523e0 commit 78a2c0a

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

core/src/main/scala/org/apache/spark/deploy/client/AppClient.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -195,8 +195,7 @@ private[spark] class AppClient(
195195
try {
196196
val timeout = RpcUtils.askTimeout(conf)
197197
val future = actor.ask(StopAppClient)(timeout.duration)
198-
// TODO(bryanc) - RpcTimeout use awaitResult ???
199-
Await.result(future, timeout.duration)
198+
timeout.awaitResult(future)
200199
} catch {
201200
case e: TimeoutException =>
202201
logInfo("Stop request to Master timed out; it may already be shut down.")

0 commit comments

Comments
 (0)