diff options
| author | Stephen Haberman <stephen@exigencecorp.com> | 2013-01-22 18:11:51 -0600 |
|---|---|---|
| committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-01-22 18:11:51 -0600 |
| commit | 98d0b7747d7539db009a9bbc261f899955871524 (patch) | |
| tree | 47ea4b4154ad42be2b3e0fe03e1ca9a3502b6415 | |
| parent | 8c51322cd05f2ae97a08c3af314c7608fcf71b57 (diff) | |
| download | spark-98d0b7747d7539db009a9bbc261f899955871524.tar.gz spark-98d0b7747d7539db009a9bbc261f899955871524.tar.bz2 spark-98d0b7747d7539db009a9bbc261f899955871524.zip | |
Fix Worker logInfo about unknown executor.
| -rw-r--r-- | core/src/main/scala/spark/deploy/worker/Worker.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/deploy/worker/Worker.scala b/core/src/main/scala/spark/deploy/worker/Worker.scala index d040b86908..5a83a42daf 100644 --- a/core/src/main/scala/spark/deploy/worker/Worker.scala +++ b/core/src/main/scala/spark/deploy/worker/Worker.scala @@ -148,7 +148,7 @@ private[spark] class Worker( logInfo("Asked to kill executor " + fullId) executor.kill() case None => - logInfo("Asked to kill non-existent existent " + fullId) + logInfo("Asked to kill unknown executor " + fullId) } case Terminated(_) | RemoteClientDisconnected(_, _) | RemoteClientShutdown(_, _) => |