From d53a51c1e5be72cd58a3ff8b62c7b680d8feae22 Mon Sep 17 00:00:00 2001
From: Bryan Cutler <cutlerb@gmail.com>
Date: Thu, 21 Apr 2016 11:33:42 +0100
Subject: [PATCH] [SPARK-14779][CORE] Corrected log message in Worker case
KillExecutor
In o.a.s.deploy.worker.Worker.scala, when receiving a KillExecutor message from an invalid Master, fixed typo by changing the log message to read "..attemped to kill executor.."
Author: Bryan Cutler <cutlerb@gmail.com>
Closes #12546 from BryanCutler/worker-killexecutor-log-message.
---
core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 449beb0811..724206bf94 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 {
--
GitLab