diff options
| author | Shixiong Zhu <shixiong@databricks.com> | 2016-09-06 16:49:06 -0700 |
|---|---|---|
| committer | Shixiong Zhu <shixiong@databricks.com> | 2016-09-06 16:49:06 -0700 |
| commit | 175b4344112b376cbbbd05265125ed0e1b87d507 (patch) | |
| tree | 25d814b57573d39fdaedab99f00c1cf4a4d911be /core/src | |
| parent | 0bd00ff2454c5046e4cb084ee64d432c4d3dcbc3 (diff) | |
| download | spark-175b4344112b376cbbbd05265125ed0e1b87d507.tar.gz spark-175b4344112b376cbbbd05265125ed0e1b87d507.tar.bz2 spark-175b4344112b376cbbbd05265125ed0e1b87d507.zip | |
[SPARK-17316][CORE] Fix the 'ask' type parameter in 'removeExecutor'
## What changes were proposed in this pull request?
Fix the 'ask' type parameter in 'removeExecutor' to eliminate a lot of error logs `Cannot cast java.lang.Boolean to scala.runtime.Nothing$`
## How was this patch tested?
Jenkins
Author: Shixiong Zhu <shixiong@databricks.com>
Closes #14983 from zsxwing/SPARK-17316-3.
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 index 6d26705377..c6b3fdf439 100644 --- 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) } |