Add ExecutionContext

zsxwing · zsxwing · commit 489dd8d09064 · 2016-08-30T17:31:29.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
@@ -414,7 +414,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val rpcEnv: Rp
     // Only log the failure since we don't care about the result.
     driverEndpoint.ask(RemoveExecutor(executorId, reason)).onFailure { case t =>
       logError(t.getMessage, t)
-    }
+    }(ThreadUtils.sameThread)
   }
 
   def sufficientResourcesRegistered(): Boolean = true

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