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");
}
/**