From c11dee708d2908c4d6f4b9aed2f14c307c8f4554 Mon Sep 17 00:00:00 2001
From: rickyma <rickyma@tencent.com>
Date: Thu, 9 May 2024 19:54:59 +0800
Subject: [PATCH] [#1686] feat(netty): Support pending tasks number metrics for
 Netty EventLoopGroup

---
 .../org/apache/uniffle/server/netty/StreamServer.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/server/src/main/java/org/apache/uniffle/server/netty/StreamServer.java b/server/src/main/java/org/apache/uniffle/server/netty/StreamServer.java
index 008a881df1..f8410fcc9d 100644
--- a/server/src/main/java/org/apache/uniffle/server/netty/StreamServer.java
+++ b/server/src/main/java/org/apache/uniffle/server/netty/StreamServer.java
@@ -64,9 +64,9 @@ public class StreamServer implements ServerInterface {
   private ShuffleServerConf shuffleServerConf;
   private ChannelFuture channelFuture;
 
-  private final ScheduledExecutorService nettyPendingTasksTracker =
+  private final ScheduledExecutorService nettyPendingTasksNumTracker =
       Executors.newSingleThreadScheduledExecutor(
-          ThreadUtils.getThreadFactory("NettyPendingTasksTracker"));
+          ThreadUtils.getThreadFactory("NettyPendingTasksNumTracker"));
   /** Interval to poll for Netty pending tasks number for Netty metrics, in milliseconds */
   private final long pendingTasksNumMetricsPollingInterval;
 
@@ -98,7 +98,7 @@ public StreamServer(ShuffleServer shuffleServer) {
   }
 
   private void startMonitoringPendingTasks() {
-    nettyPendingTasksTracker.scheduleAtFixedRate(
+    nettyPendingTasksNumTracker.scheduleAtFixedRate(
         () -> {
           int pendingTasksNumForBossGroup = getPendingTasksForEventLoopGroup(shuffleBossGroup);
           shuffleServer
@@ -219,8 +219,8 @@ public void stop() {
       shuffleBossGroup = null;
       shuffleWorkerGroup = null;
     }
-    if (!nettyPendingTasksTracker.isShutdown()) {
-      nettyPendingTasksTracker.shutdown();
+    if (!nettyPendingTasksNumTracker.isShutdown()) {
+      nettyPendingTasksNumTracker.shutdown();
     }
   }