Fix the 'ask' type parameter in 'removeExecutor'

zsxwing · zsxwing · commit 1ba43d681f06 · 2016-09-06T14:02:59.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala
@@ -416,7 +416,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
    */
   protected def removeExecutor(executorId: String, reason: ExecutorLossReason): Unit = {
     // Only log the failure since we don't care about the result.
-    driverEndpoint.ask(RemoveExecutor(executorId, reason)).onFailure { case t =>
+    driverEndpoint.ask[Boolean](RemoveExecutor(executorId, reason)).onFailure { case t =>
       logError(t.getMessage, t)
     }(ThreadUtils.sameThread)
   }

Original file line number	Diff line number	Diff line change
`@@ -416,7 +416,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp`
`416`	`416`	`*/`
`417`	`417`	`protected def removeExecutor(executorId: String, reason: ExecutorLossReason): Unit = {`
`418`	`418`	`// Only log the failure since we don't care about the result.`
`419`		`- driverEndpoint.ask(RemoveExecutor(executorId, reason)).onFailure { case t =>`
	`419`	`+ driverEndpoint.ask[Boolean](RemoveExecutor(executorId, reason)).onFailure { case t =>`
`420`	`420`	`logError(t.getMessage, t)`
`421`	`421`	`}(ThreadUtils.sameThread)`
`422`	`422`	`}`