Github user devaraj-kavali commented on a diff in the pull request:
https://github.com/apache/spark/pull/19741#discussion_r151303638
--- Diff:
resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnSchedulerBackend.scala
---
@@ -268,8 +268,13 @@ private[spark] abstract class YarnSchedulerBackend(
logWarning(reason.toString)
driverEndpoint.ask[Boolean](r).onFailure {
--- End diff --
Thanks @vanzin for the review.
I think it is a good suggestion, there are other places where the
`RemoveExecutor` message is sending using the `ask`, are you suggesting to
change those as well?
> (And the driver endpoint will probably need a minor change too.)
You mean moving the case `RemoveExecutor(executorId, reason)` from
`receiveAndReply` to `receive`?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
