diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManagerMaster.scala b/core/src/main/scala/org/apache/spark/storage/BlockManagerMaster.scala index f229a607c6cec..0bbc2d2b5ca1b 100644 --- a/core/src/main/scala/org/apache/spark/storage/BlockManagerMaster.scala +++ b/core/src/main/scala/org/apache/spark/storage/BlockManagerMaster.scala @@ -42,8 +42,8 @@ class BlockManagerMaster( logInfo("Removed " + execId + " successfully in removeExecutor") } - /** Request removal of a dead executor from the driver endpoint. - * This is only called on the driver side. Non-blocking + /** Request removal of a dead executor from the driver endpoint. + * This is only called on the driver side. Non-blocking */ def removeExecutorAsync(execId: String) { driverEndpoint.ask[Boolean](RemoveExecutor(execId))