(auron) branch master updated: [AURON #2137] Native thread name appends the original thread name (#2144)

[shreyesh]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 3518098e [AURON #2137] Native thread name appends the original thread 
name (#2144)
3518098e is described below

commit 3518098e62736a1537e45bcef41cccce85f7d070
Author: cxzl25 <3898450+cxz...@users.noreply.github.com>
AuthorDate: Wed Apr 1 07:11:52 2026 +0800

    [AURON #2137] Native thread name appends the original thread name (#2144)
    
    # Which issue does this PR close?
    
    Closes #2137
    
    # Rationale for this change
    
    # What changes are included in this PR?
    
    # Are there any user-facing changes?
    
    # How was this patch tested?
---
 .../scala/org/apache/spark/sql/auron/util/TaskContextHelper.scala    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/spark-extension/src/main/scala/org/apache/spark/sql/auron/util/TaskContextHelper.scala
 
b/spark-extension/src/main/scala/org/apache/spark/sql/auron/util/TaskContextHelper.scala
index 8e5d7353..309139eb 100644
--- 
a/spark-extension/src/main/scala/org/apache/spark/sql/auron/util/TaskContextHelper.scala
+++ 
b/spark-extension/src/main/scala/org/apache/spark/sql/auron/util/TaskContextHelper.scala
@@ -45,12 +45,13 @@ object TaskContextHelper extends Logging {
   def setNativeThreadName(): Unit = {
     val context: TaskContext = TaskContext.get()
     val thread = Thread.currentThread()
-    val threadName = if (context != null) {
+    val threadPrefix = if (context != null) {
       s"auron native task ${context.partitionId()}.${context.attemptNumber()} 
in stage ${context
         .stageId()}.${context.stageAttemptNumber()} (TID 
${context.taskAttemptId()})"
     } else {
-      "auron native task " + thread.getName
+      "auron native task"
     }
+    val threadName = threadPrefix + " " + thread.getName
     thread.setName(threadName)
   }