(flink) 05/05: [hotfix][runtime] Including task name and subtask index into channel-state-unspilling thread name

[fanrui]

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

fanrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit ebaa7b8420b72c2dc91e2deb19314f9b7333824f
Author: Rui Fan <1996fan...@gmail.com>
AuthorDate: Thu Jan 15 17:37:31 2026 +0100

    [hotfix][runtime] Including task name and subtask index into 
channel-state-unspilling thread name
---
 .../java/org/apache/flink/streaming/runtime/tasks/StreamTask.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
 
b/flink-runtime/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
index 07167659cb0..a07d5ee3915 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
@@ -421,11 +421,13 @@ public abstract class StreamTask<OUT, OP extends 
StreamOperator<OUT>>
             // Should be closed last.
             resourceCloser.registerCloseable(mailboxProcessor);
 
+            String unspillingThreadName =
+                    String.format("channel-state-unspilling-%s", 
getTaskNameWithSubtaskAndId());
             this.channelIOExecutor =
                     MdcUtils.scopeToJob(
                             environment.getJobID(),
                             Executors.newSingleThreadExecutor(
-                                    new 
ExecutorThreadFactory("channel-state-unspilling")));
+                                    new 
ExecutorThreadFactory(unspillingThreadName)));
             resourceCloser.registerCloseable(channelIOExecutor::shutdown);
 
             this.recordWriter = createRecordWriterDelegate(configuration, 
environment);