From ab83a154b6153c72b1e48b26d291799349ab3dd3 Mon Sep 17 00:00:00 2001
From: Junfan Zhang <zhangjunfan@qiyi.com>
Date: Tue, 19 Nov 2024 10:24:54 +0800
Subject: [PATCH] [#2241][FOLLOWUP] improvement(server): Mark the underlying
 thread name

---
 .../org/apache/uniffle/server/DefaultFlushEventHandler.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/server/src/main/java/org/apache/uniffle/server/DefaultFlushEventHandler.java b/server/src/main/java/org/apache/uniffle/server/DefaultFlushEventHandler.java
index 49f6463ee4..6284b933c8 100644
--- a/server/src/main/java/org/apache/uniffle/server/DefaultFlushEventHandler.java
+++ b/server/src/main/java/org/apache/uniffle/server/DefaultFlushEventHandler.java
@@ -103,7 +103,8 @@ private void consumeEvent(ShuffleDataFlushEvent event) throws Exception {
           }
           return null;
         };
-    CompletableFutureUtils.withTimeoutCancel(supplier, flushMaxWaitTimeoutSec * 1000);
+    CompletableFutureUtils.withTimeoutCancel(
+        supplier, flushMaxWaitTimeoutSec * 1000, "event-flushing");
   }
 
   /**