diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java index 9b47431d76d..0a033c48ff7 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java @@ -475,12 +475,31 @@ protected void setRMStateStore(RMStateStore rmStore) { protected Dispatcher createDispatcher() { AsyncDispatcher dispatcher = new AsyncDispatcher("RM Event dispatcher"); - GenericEventTypeMetrics genericEventTypeMetrics = + + // Add 4 busy event types. + dispatcher.addMetrics(GenericEventTypeMetricsManager. + create(dispatcher.getName(), NodesListManagerEventType.class), + GenericEventTypeMetricsManager. + create(dispatcher.getName(), NodesListManagerEventType.class) + .getEnumClass()); + + dispatcher.addMetrics(GenericEventTypeMetricsManager. + create(dispatcher.getName(), RMNodeEventType.class), + GenericEventTypeMetricsManager. + create(dispatcher.getName(), RMNodeEventType.class) + .getEnumClass()); + + dispatcher.addMetrics(GenericEventTypeMetricsManager. + create(dispatcher.getName(), RMAppEventType.class), + GenericEventTypeMetricsManager. + create(dispatcher.getName(), RMAppEventType.class) + .getEnumClass()); + + dispatcher.addMetrics(GenericEventTypeMetricsManager. + create(dispatcher.getName(), RMAppAttemptEventType.class), GenericEventTypeMetricsManager. - create(dispatcher.getName(), NodesListManagerEventType.class); - // We can add more - dispatcher.addMetrics(genericEventTypeMetrics, - genericEventTypeMetrics.getEnumClass()); + create(dispatcher.getName(), RMAppAttemptEventType.class) + .getEnumClass()); return dispatcher; }