diff options
| author | Bryan Cutler <cutlerb@gmail.com> | 2016-04-21 11:33:42 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-04-21 11:33:42 +0100 |
| commit | d53a51c1e5be72cd58a3ff8b62c7b680d8feae22 (patch) | |
| tree | dc061b474fb55e52077a31f7c64d050b134f80d5 | |
| parent | ec2a276022568944e19a51d4d39305710cdc7c0f (diff) | |
| download | spark-d53a51c1e5be72cd58a3ff8b62c7b680d8feae22.tar.gz spark-d53a51c1e5be72cd58a3ff8b62c7b680d8feae22.tar.bz2 spark-d53a51c1e5be72cd58a3ff8b62c7b680d8feae22.zip | |
[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.
| -rwxr-xr-x | core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 { |