Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-10997. Revisit allocation and reservation logging. Contributed by Andras Gyori 

(cherry picked from commit 7cb887e6c2)
This commit is contained in:
Szilard Nemeth 2021-11-12 15:42:14 +01:00 committed by Eric Payne
parent cdbc2bac02
commit de35dd819a
2 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java
View File

@ -3074,13 +3074,11 @@ public class CapacityScheduler extends
long commitSuccess = System.nanoTime() - commitStart; long commitSuccess = System.nanoTime() - commitStart;
CapacitySchedulerMetrics.getMetrics() CapacitySchedulerMetrics.getMetrics()
.addCommitSuccess(commitSuccess); .addCommitSuccess(commitSuccess);
LOG.info("Allocation proposal accepted");
isSuccess = true; isSuccess = true;
} else{ } else{
long commitFailed = System.nanoTime() - commitStart; long commitFailed = System.nanoTime() - commitStart;
CapacitySchedulerMetrics.getMetrics() CapacitySchedulerMetrics.getMetrics()
.addCommitFailure(commitFailed); .addCommitFailure(commitFailed);
LOG.info("Failed to accept allocation proposal");
} }
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {

13
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/common/fica/FiCaSchedulerApp.java
View File

@ -358,6 +358,7 @@ public class FiCaSchedulerApp extends SchedulerApplicationAttempt {
// adding NP check as this proposal could not be allocated from reserved // adding NP check as this proposal could not be allocated from reserved
// container in async-scheduling mode // container in async-scheduling mode
if (allocation.getAllocateFromReservedContainer() == null) { if (allocation.getAllocateFromReservedContainer() == null) {
LOG.debug("Trying to allocate from reserved container in async scheduling mode");
return false; return false;
} }
RMContainer fromReservedContainer = RMContainer fromReservedContainer =
@ -576,6 +577,8 @@ public class FiCaSchedulerApp extends SchedulerApplicationAttempt {
if (updatePending && if (updatePending &&
getOutstandingAsksCount(schedulerContainer.getSchedulerRequestKey()) getOutstandingAsksCount(schedulerContainer.getSchedulerRequestKey())
<= 0) { <= 0) {
LOG.debug("Rejecting appliance of allocation due to existing pending allocation " +
"request for " + schedulerContainer);
return false; return false;
} }
@ -674,10 +677,12 @@ public class FiCaSchedulerApp extends SchedulerApplicationAttempt {
schedulerContainer.getRmContainer().getContainer(), schedulerContainer.getRmContainer().getContainer(),
reReservation); reReservation);
LOG.info("Reserved container=" + rmContainer.getContainerId() if (LOG.isDebugEnabled()) {
+ ", on node=" + schedulerContainer.getSchedulerNode() LOG.debug("Reserved container=" + rmContainer.getContainerId()
+ " with resource=" + rmContainer + ", on node=" + schedulerContainer.getSchedulerNode()
.getAllocatedOrReservedResource()); + " with resource=" + rmContainer
.getAllocatedOrReservedResource());
}
} }
} }
} finally { } finally {