HDFS-17433. metrics sumOfActorCommandQueueLength should only record valid commands. (#6644)

2024-03-21 11:41:35 +08:00 · 2024-03-21 11:41:35 +08:00 · 2eb7246ea7
commit 2eb7246ea7
parent 77c600d769
1 changed files with 4 additions and 2 deletions
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java
@ -1487,10 +1487,12 @@ void enqueue(List<DatanodeCommand> cmds) throws InterruptedException {
    }

    void enqueue(DatanodeCommand[] cmds) throws InterruptedException {
+      if (cmds.length != 0) {
        queue.put(() -> processCommand(cmds));
        dn.getMetrics().incrActorCmdQueueLength(1);
      }
    }
+  }

  @VisibleForTesting
  void stopCommandProcessingThread() {