[apache#1686] feat(netty): Support pending tasks number metrics for N…

…etty EventLoopGroup
rickyma · May 9, 2024 · c11dee7 · c11dee7
1 parent a057f2e
commit c11dee7
Showing 1 changed file with 5 additions and 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
@@ -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();
     }
   }