(flink) 01/02: [hotfix][runtime] Adds ComponentMainThread to thread name of ComponentMainThreadExecutorServiceAdapter

[mapohl]

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);
     }