Repository: hadoop Updated Branches: refs/heads/branch-2 dcfce5fcd -> e0b143e51
Revert "YARN-6298. Metric preemptCall is not used in new preemption. (Yufei Gu via kasha)" This reverts commit dcfce5fcddcfdd23392586c87adf7c14e8ef265e. Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/e0b143e5 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/e0b143e5 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/e0b143e5 Branch: refs/heads/branch-2 Commit: e0b143e51adf6b16ae9220e0e30c0d3827a518b7 Parents: dcfce5f Author: Karthik Kambatla <[email protected]> Authored: Fri Apr 7 17:37:31 2017 -0700 Committer: Karthik Kambatla <[email protected]> Committed: Fri Apr 7 17:37:31 2017 -0700 ---------------------------------------------------------------------- .../server/resourcemanager/scheduler/fair/FSOpDurations.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/e0b143e5/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 6676baf..20d2af9 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 @@ -53,6 +53,9 @@ public class FSOpDurations implements MetricsSource { @Metric("Duration for an update call") MutableRate updateCall; + @Metric("Duration for a preempt call") + MutableRate preemptCall; + private static final MetricsInfo RECORD_INFO = info("FSOpDurations", "Durations of FairScheduler calls or thread-runs"); @@ -85,6 +88,7 @@ public class FSOpDurations implements MetricsSource { nodeUpdateCall.setExtended(isExtended); updateThreadRun.setExtended(isExtended); updateCall.setExtended(isExtended); + preemptCall.setExtended(isExtended); INSTANCE.isExtended = isExtended; } @@ -110,6 +114,10 @@ public class FSOpDurations implements MetricsSource { updateCall.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]
