From 2aa8967809b05e558b36ab6fc8c5110ddb723b45 Mon Sep 17 00:00:00 2001 From: Karthik Kambatla Date: Fri, 7 Apr 2017 17:31:50 -0700 Subject: [PATCH] YARN-6298. Metric preemptCall is not used in new preemption. (Yufei Gu via kasha) --- .../resourcemanager/scheduler/fair/FSOpDurations.java | 8 -------- 1 file changed, 8 deletions(-) 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 f6d843ae0bf..c841ca76ac9 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();