diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSOpDurations.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSOpDurations.java index 20d2af9..f6d843a 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSOpDurations.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSOpDurations.java @@ -50,9 +50,6 @@ @Metric("Duration for a update thread run") MutableRate updateThreadRun; - @Metric("Duration for an update call") - MutableRate updateCall; - @Metric("Duration for a preempt call") MutableRate preemptCall; @@ -87,7 +84,6 @@ private synchronized void setExtended(boolean isExtended) { continuousSchedulingRun.setExtended(isExtended); nodeUpdateCall.setExtended(isExtended); updateThreadRun.setExtended(isExtended); - updateCall.setExtended(isExtended); preemptCall.setExtended(isExtended); INSTANCE.isExtended = isExtended; @@ -110,10 +106,6 @@ public void addUpdateThreadRunDuration(long value) { updateThreadRun.add(value); } - public void addUpdateCallDuration(long value) { - updateCall.add(value); - } - public void addPreemptCallDuration(long value) { preemptCall.add(value); } diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java index 97871e7..134efff 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FairScheduler.java @@ -350,7 +350,6 @@ public void run() { protected void update() { try { writeLock.lock(); - long start = getClock().getTime(); FSQueue rootQueue = queueMgr.getRootQueue(); @@ -373,9 +372,6 @@ protected void update() { rootMetrics.getAvailableVirtualCores()) + " Demand: " + rootQueue.getDemand()); } - - long duration = getClock().getTime() - start; - fsOpDurations.addUpdateCallDuration(duration); } } finally { writeLock.unlock();