diff options
| author | Peter Ableda <abledapeter@gmail.com> | 2016-06-13 09:40:17 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-06-13 09:40:17 +0100 |
| commit | d681742b2d37bd68cf5d8d3161e0f48846f6f9d4 (patch) | |
| tree | 4fbea2ffd351e41d9aa61a468aa4ea2ef2e2bc3b /yarn/src | |
| parent | e2ab79d5ea00af45c083cc9a6607d2f0905f9908 (diff) | |
| download | spark-d681742b2d37bd68cf5d8d3161e0f48846f6f9d4.tar.gz spark-d681742b2d37bd68cf5d8d3161e0f48846f6f9d4.tar.bz2 spark-d681742b2d37bd68cf5d8d3161e0f48846f6f9d4.zip | |
[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 <abledapeter@gmail.com>
Closes #13552 from peterableda/patch-1.
Diffstat (limited to 'yarn/src')
| -rw-r--r-- | yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala | 3 |
1 files changed, 2 insertions, 1 deletions
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 b110d82fb8..1b80071649 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) { |