Add the return type

zsxwing · zsxwing · commit 142de67e2eac · 2016-08-30T16:52:38.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
@@ -408,7 +408,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
   }
 
   // Called by subclasses when notified of a lost worker
-  protected def removeExecutor(executorId: String, reason: ExecutorLossReason) {
+  protected def removeExecutor(executorId: String, reason: ExecutorLossReason): Unit = {
     try {
       driverEndpoint.askWithRetry[Boolean](RemoveExecutor(executorId, reason))
     } catch {

Original file line number	Diff line number	Diff line change
`@@ -408,7 +408,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp`
`408`	`408`	`}`
`409`	`409`
`410`	`410`	`// Called by subclasses when notified of a lost worker`
`411`		`- protected def removeExecutor(executorId: String, reason: ExecutorLossReason) {`
	`411`	`+ protected def removeExecutor(executorId: String, reason: ExecutorLossReason): Unit = {`
`412`	`412`	`try {`
`413`	`413`	`driverEndpoint.askWithRetry[Boolean](RemoveExecutor(executorId, reason))`
`414`	`414`	`} catch {`