This is an automated email from the ASF dual-hosted git repository.

zuston pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git


The following commit(s) were added to refs/heads/master by this push:
     new c1bfa043d [#2241][FOLLOWUP] improvement(server): Mark the underlying 
thread name (#2256)
c1bfa043d is described below

commit c1bfa043db703210f7e1367734654e5b1dd82c7b
Author: Junfan Zhang <[email protected]>
AuthorDate: Tue Nov 19 11:18:04 2024 +0800

    [#2241][FOLLOWUP] improvement(server): Mark the underlying thread name 
(#2256)
    
    ### What changes were proposed in this pull request?
    
    Mark the underlying thread name for flushing events
    
    ### Why are the changes needed?
    
    The follow up pr for #2241
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    needn't
    
    
    Co-authored-by: Junfan Zhang <[email protected]>
---
 .../main/java/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 49f6463ee..6284b933c 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 @@ public class DefaultFlushEventHandler implements 
FlushEventHandler {
           }
           return null;
         };
-    CompletableFutureUtils.withTimeoutCancel(supplier, flushMaxWaitTimeoutSec 
* 1000);
+    CompletableFutureUtils.withTimeoutCancel(
+        supplier, flushMaxWaitTimeoutSec * 1000, "event-flushing");
   }
 
   /**

Reply via email to