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 | |
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')
-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) } |