YARN-10797. Logging parameter issues in scheduler package. Contributed by Szilard Nemeth

This commit is contained in:
Gergely Pollak 2021-06-01 15:57:22 +02:00
parent b38b00e528
commit e9339aa376
2 changed files with 2 additions and 2 deletions

View File

@ -140,7 +140,7 @@ public class QueueConfigurationAutoRefreshPolicy
LOG.error("Can't refresh queue: " + e); LOG.error("Can't refresh queue: " + e);
if (!lastReloadAttemptFailed) { if (!lastReloadAttemptFailed) {
LOG.error("Failed to reload capacity scheduler config file - " + LOG.error("Failed to reload capacity scheduler config file - " +
"will use existing conf.", e.getMessage()); "will use existing conf. Message: {}", e.getMessage());
} }
lastReloadAttempt = clock.getTime(); lastReloadAttempt = clock.getTime();
lastReloadAttemptFailed = true; lastReloadAttemptFailed = true;

View File

@ -1200,7 +1200,7 @@ public class FiCaSchedulerApp extends SchedulerApplicationAttempt {
targetNode.reserveResource(this, targetNode.reserveResource(this,
reservedContainer.getReservedSchedulerKey(), reservedContainer); reservedContainer.getReservedSchedulerKey(), reservedContainer);
} catch (IllegalStateException e) { } catch (IllegalStateException e) {
LOG.debug("Reserve on target node failed, e={}", e); LOG.debug("Reserve on target node failed", e);
return false; return false;
} }