HADOOP-17995. Fix

huhaiyang · huhaiyang · commit aff0c48846ff · 2021-11-09T11:34:09.000+08:00
diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/lib/MutableRollingAverages.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/lib/MutableRollingAverages.java
@@ -167,7 +167,7 @@ synchronized void replaceScheduledTask(int windows, long interval,
   }
 
   @Override
-  public void snapshot(MetricsRecordBuilder builder, boolean all) {
+  public synchronized void snapshot(MetricsRecordBuilder builder, boolean all) {
     if (all || changed()) {
       for (final Entry<String, LinkedBlockingDeque<SumAndCount>> entry
           : averages.entrySet()) {

Original file line number	Diff line number	Diff line change
`@@ -167,7 +167,7 @@ synchronized void replaceScheduledTask(int windows, long interval,`
`167`	`167`	`}`
`168`	`168`
`169`	`169`	`@Override`
`170`		`- public void snapshot(MetricsRecordBuilder builder, boolean all) {`
	`170`	`+ public synchronized void snapshot(MetricsRecordBuilder builder, boolean all) {`
`171`	`171`	`if (all \|\| changed()) {`
`172`	`172`	`for (final Entry<String, LinkedBlockingDeque<SumAndCount>> entry`
`173`	`173`	`: averages.entrySet()) {`