Repository: spark Updated Branches: refs/heads/branch-2.0 b96e7f6aa -> 41f309bfb
[SPARK-15813] Improve Canceling log message to make it less ambiguous ## What changes were proposed in this pull request? Add new desired executor number to make the log message less ambiguous. ## How was this patch tested? This is a trivial change Author: Peter Ableda <abledape...@gmail.com> Closes #13552 from peterableda/patch-1. (cherry picked from commit d681742b2d37bd68cf5d8d3161e0f48846f6f9d4) Signed-off-by: Sean Owen <so...@cloudera.com> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/41f309bf Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/41f309bf Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/41f309bf Branch: refs/heads/branch-2.0 Commit: 41f309bfbcefcc9612efb7c0571a4009147e5896 Parents: b96e7f6 Author: Peter Ableda <abledape...@gmail.com> Authored: Mon Jun 13 09:40:17 2016 +0100 Committer: Sean Owen <so...@cloudera.com> Committed: Mon Jun 13 09:40:25 2016 +0100 ---------------------------------------------------------------------- .../main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/41f309bf/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala ---------------------------------------------------------------------- diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala index b110d82..1b80071 100644 --- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala +++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala @@ -354,7 +354,8 @@ private[yarn] class YarnAllocator( } else if (missing < 0) { val numToCancel = math.min(numPendingAllocate, -missing) - logInfo(s"Canceling requests for $numToCancel executor containers") + logInfo(s"Canceling requests for $numToCancel executor container(s) to have a new desired " + + s"total $targetNumExecutors executors.") val matchingRequests = amClient.getMatchingRequests(RM_REQUEST_PRIORITY, ANY_HOST, resource) if (!matchingRequests.isEmpty) { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
