YARN-11656 RMStateStore event queue blocked

- fix thread name
- sort log records in monitor

Author: K0K0V0K

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/multidispatcher/MultiDispatcher.java

@@ -135,9 +135,10 @@ private void createMonitorThread(MultiDispatcherConfig config) {
             .namingPattern(this.dispatcherName + "-monitor-%d")
             .build());
     monitorExecutor.scheduleAtFixedRate(() -> {
-      List<String> notEmptyQueues = workerExecutor.getQueueSize().entrySet().stream()
+      List<String> notEmptyQueues = workerExecutor.getQueuesSize().entrySet().stream()
           .filter(e -> 0 < e.getValue())
           .map(e -> String.format("%s has queue size %d", e.getKey(), e.getValue()))
+          .sorted()
           .collect(Collectors.toList());
       if (!notEmptyQueues.isEmpty()) {
         log.info("Event queue sizes: {}", notEmptyQueues);

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/event/multidispatcher/MultiDispatcherExecutor.java

@@ -78,7 +78,7 @@ public void stop() throws InterruptedException {
     }
   }
 
-  public Map<String, Long> getQueueSize() {
+  public Map<String, Long> getQueuesSize() {
     return Arrays.stream(threads).collect(Collectors.toMap(
         MultiDispatcherExecutorThread::getName,
         MultiDispatcherExecutorThread::queueSize
@@ -89,7 +89,7 @@ private final class MultiDispatcherExecutorThread extends Thread {
     private final BlockingQueue<Runnable> queue;
 
     MultiDispatcherExecutorThread(ThreadGroup group, int index, int queueSize) {
-      super(group, String.format("Thread-%d", index));
+      super(group, String.format("%s-worker-%d", group.getName(), index));
       this.queue = new LinkedBlockingQueue<>(queueSize);
     }