YARN-6298. Metric preemptCall is not used in new preemption. (Yufei Gu via kasha)
This commit is contained in:
parent
e8bdad7385
commit
2aa8967809
|
@ -50,9 +50,6 @@ public class FSOpDurations implements MetricsSource {
|
||||||
@Metric("Duration for a update thread run")
|
@Metric("Duration for a update thread run")
|
||||||
MutableRate updateThreadRun;
|
MutableRate updateThreadRun;
|
||||||
|
|
||||||
@Metric("Duration for a preempt call")
|
|
||||||
MutableRate preemptCall;
|
|
||||||
|
|
||||||
private static final MetricsInfo RECORD_INFO =
|
private static final MetricsInfo RECORD_INFO =
|
||||||
info("FSOpDurations", "Durations of FairScheduler calls or thread-runs");
|
info("FSOpDurations", "Durations of FairScheduler calls or thread-runs");
|
||||||
|
|
||||||
|
@ -84,7 +81,6 @@ public class FSOpDurations implements MetricsSource {
|
||||||
continuousSchedulingRun.setExtended(isExtended);
|
continuousSchedulingRun.setExtended(isExtended);
|
||||||
nodeUpdateCall.setExtended(isExtended);
|
nodeUpdateCall.setExtended(isExtended);
|
||||||
updateThreadRun.setExtended(isExtended);
|
updateThreadRun.setExtended(isExtended);
|
||||||
preemptCall.setExtended(isExtended);
|
|
||||||
|
|
||||||
INSTANCE.isExtended = isExtended;
|
INSTANCE.isExtended = isExtended;
|
||||||
}
|
}
|
||||||
|
@ -106,10 +102,6 @@ public class FSOpDurations implements MetricsSource {
|
||||||
updateThreadRun.add(value);
|
updateThreadRun.add(value);
|
||||||
}
|
}
|
||||||
|
|
||||||
public void addPreemptCallDuration(long value) {
|
|
||||||
preemptCall.add(value);
|
|
||||||
}
|
|
||||||
|
|
||||||
@VisibleForTesting
|
@VisibleForTesting
|
||||||
public boolean hasUpdateThreadRunChanged() {
|
public boolean hasUpdateThreadRunChanged() {
|
||||||
return updateThreadRun.changed();
|
return updateThreadRun.changed();
|
||||||
|
|
Loading…
Reference in New Issue