diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala b/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala index 449beb08111774821ae4e27ead90bd8f32a64ac4..724206bf94c6866daa1c2b93882c4623c127545e 100755 --- a/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala +++ b/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala @@ -496,7 +496,7 @@ private[deploy] class Worker( case KillExecutor(masterUrl, appId, execId) => if (masterUrl != activeMasterUrl) { - logWarning("Invalid Master (" + masterUrl + ") attempted to launch executor " + execId) + logWarning("Invalid Master (" + masterUrl + ") attempted to kill executor " + execId) } else { val fullId = appId + "/" + execId executors.get(fullId) match {