Index: hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java (date 1618375862000) +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/AsyncDispatcher.java (date 1618578484000) @@ -26,6 +26,7 @@ import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; +import org.apache.hadoop.util.Time; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.slf4j.Marker; @@ -276,20 +277,26 @@ } class GenericEventHandler implements EventHandler { + + private long lastTime = Time.monotonicNow(); private void printEventQueueDetails() { - Iterator iterator = eventQueue.iterator(); - Map counterMap = new HashMap<>(); - while (iterator.hasNext()) { - Enum eventType = iterator.next().getType(); - if (!counterMap.containsKey(eventType)) { - counterMap.put(eventType, 0L); - } - counterMap.put(eventType, counterMap.get(eventType) + 1); - } - for (Map.Entry entry : counterMap.entrySet()) { - long num = entry.getValue(); - LOG.info("Event type: " + entry.getKey() - + ", Event record counter: " + num); + //Avoid High-Frequency printEventQueueDetails + if (Time.monotonicNow() - lastTime > 30000) { + Iterator iterator = eventQueue.iterator(); + Map counterMap = new HashMap<>(); + while (iterator.hasNext()) { + Enum eventType = iterator.next().getType(); + if (!counterMap.containsKey(eventType)) { + counterMap.put(eventType, 0L); + } + counterMap.put(eventType, counterMap.get(eventType) + 1); + } + for (Map.Entry entry : counterMap.entrySet()) { + long num = entry.getValue(); + LOG.info("Event type: " + entry.getKey() + + ", Event record counter: " + num); + } + lastTime = Time.monotonicNow(); } } public void handle(Event event) {