From d681742b2d37bd68cf5d8d3161e0f48846f6f9d4 Mon Sep 17 00:00:00 2001
From: Peter Ableda <abledapeter@gmail.com>
Date: Mon, 13 Jun 2016 09:40:17 +0100
Subject: [PATCH] [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.
---
.../scala/org/apache/spark/deploy/yarn/YarnAllocator.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
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) {
--
GitLab