You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2024/08/29 15:23:23 UTC
(flink) 01/02: [hotfix][runtime] Adds ComponentMainThread to thread name of ComponentMainThreadExecutorServiceAdapter
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit e207a4598834b6665dbd12e6f964e924dfa67b1d
Author: Matthias Pohl <mp...@confluent.io>
AuthorDate: Thu Aug 1 08:43:56 2024 +0200
[hotfix][runtime] Adds ComponentMainThread to thread name of ComponentMainThreadExecutorServiceAdapter
---
.../runtime/concurrent/ComponentMainThreadExecutorServiceAdapter.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ComponentMainThreadExecutorServiceAdapter.java b/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ComponentMainThreadExecutorServiceAdapter.java
index 55ac8bce611..690ccecf227 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ComponentMainThreadExecutorServiceAdapter.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ComponentMainThreadExecutorServiceAdapter.java
@@ -78,6 +78,7 @@ public class ComponentMainThreadExecutorServiceAdapter implements ComponentMainT
@Nonnull ScheduledExecutorService singleThreadExecutor) {
final Thread thread =
CompletableFuture.supplyAsync(Thread::currentThread, singleThreadExecutor).join();
+ thread.setName(String.format("ComponentMainThread-%s", thread.getName()));
return new ComponentMainThreadExecutorServiceAdapter(singleThreadExecutor, thread);
}