YARN-6298. Metric preemptCall is not used in new preemption. (Yufei Gu via kasha)
(cherry picked from commit 2aa8967809b05e558b36ab6fc8c5110ddb723b45)
This commit is contained in:
parent
ff2870310e
commit
dcfce5fcdd
@ -53,9 +53,6 @@ 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");
|
||||
|
||||
@ -88,7 +85,6 @@ private synchronized void setExtended(boolean isExtended) {
|
||||
nodeUpdateCall.setExtended(isExtended);
|
||||
updateThreadRun.setExtended(isExtended);
|
||||
updateCall.setExtended(isExtended);
|
||||
preemptCall.setExtended(isExtended);
|
||||
|
||||
INSTANCE.isExtended = isExtended;
|
||||
}
|
||||
@ -114,10 +110,6 @@ public void addUpdateCallDuration(long value) {
|
||||
updateCall.add(value);
|
||||
}
|
||||
|
||||
public void addPreemptCallDuration(long value) {
|
||||
preemptCall.add(value);
|
||||
}
|
||||
|
||||
@VisibleForTesting
|
||||
public boolean hasUpdateThreadRunChanged() {
|
||||
return updateThreadRun.changed();
|
||||
|
Loading…
x
Reference in New Issue
Block a user