From aba9184cb4d80aaccb4ee68866ef4c6f9e719561 Mon Sep 17 00:00:00 2001 From: roxchkplusony Date: Wed, 26 Nov 2014 13:24:30 -0800 Subject: [PATCH] replace warning message per review --- .../scheduler/cluster/CoarseGrainedSchedulerBackend.scala | 3 +-- 1 file changed, 1 insertion(+), 2 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 f3636170fb382..88b196ac64368 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 @@ -132,8 +132,7 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, val actorSyste executorInfo.executorActor ! KillTask(taskId, executorId, interruptThread) case None => // Ignoring the task kill since the executor is not registered. - logWarning(s"Ignored task kill $taskId $executorId" - + " for unknown executor $sender with ID $executorId") + logWarning(s"Attempted to kill task $taskId for unknown executor $executorId.") } case StopDriver =>