This is an automated email from the ASF dual-hosted git repository. roryqi pushed a commit to branch branch-0.10 in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git
commit cce120068deb687d1f10cb1fa533e119f1fbefdf 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"); } /**
