YARN-6298. Metric preemptCall is not used in new preemption. (Yufei Gu via kasha)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/b096340c Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/b096340c Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/b096340c Branch: refs/heads/HDFS-10467 Commit: b096340cee2bc728cb8d1c948bd4f2a99aca0b2a Parents: 57e97ce Author: Karthik Kambatla <[email protected]> Authored: Fri Apr 7 17:31:50 2017 -0700 Committer: Inigo <[email protected]> Committed: Mon Apr 17 11:16:59 2017 -0700 ---------------------------------------------------------------------- .../server/resourcemanager/scheduler/fair/FSOpDurations.java | 8 -------- 1 file changed, 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/b096340c/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 ---------------------------------------------------------------------- diff --git a/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 b/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 f6d843a..c841ca7 100644 --- a/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 +++ b/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 @@ public class FSOpDurations implements MetricsSource { @Metric("Duration for a update thread run") MutableRate updateThreadRun; - @Metric("Duration for a preempt call") - MutableRate preemptCall; - private static final MetricsInfo RECORD_INFO = info("FSOpDurations", "Durations of FairScheduler calls or thread-runs"); @@ -84,7 +81,6 @@ public class FSOpDurations implements MetricsSource { continuousSchedulingRun.setExtended(isExtended); nodeUpdateCall.setExtended(isExtended); updateThreadRun.setExtended(isExtended); - preemptCall.setExtended(isExtended); INSTANCE.isExtended = isExtended; } @@ -106,10 +102,6 @@ public class FSOpDurations implements MetricsSource { updateThreadRun.add(value); } - public void addPreemptCallDuration(long value) { - preemptCall.add(value); - } - @VisibleForTesting public boolean hasUpdateThreadRunChanged() { return updateThreadRun.changed(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
