(auron) branch master updated: [AURON #2147] Set thread name for ArrowFFIExporter (#2148)

[csy]

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

csy 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 edaac4a3 [AURON #2147] Set thread name for ArrowFFIExporter (#2148)
edaac4a3 is described below

commit edaac4a354b911e365bd2fbdac8cfc01912744a0
Author: cxzl25 <3898450+cxz...@users.noreply.github.com>
AuthorDate: Thu Apr 2 10:48:10 2026 +0800

    [AURON #2147] Set thread name for ArrowFFIExporter (#2148)
    
    # Which issue does this PR close?
    
    Closes #2147
    
    # Rationale for this change
    
    # What changes are included in this PR?
    
    # Are there any user-facing changes?
    
    # How was this patch tested?
---
 .../org/apache/spark/sql/execution/auron/arrowio/ArrowFFIExporter.scala  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/arrowio/ArrowFFIExporter.scala
 
b/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/arrowio/ArrowFFIExporter.scala
index 0192aa35..cc167859 100644
--- 
a/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/arrowio/ArrowFFIExporter.scala
+++ 
b/spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/arrowio/ArrowFFIExporter.scala
@@ -160,6 +160,7 @@ class ArrowFFIExporter(rowIter: Iterator[InternalRow], 
schema: StructType)
       tc.addTaskFailureListener((_, _) => close())
     }
 
+    thread.setName(s"ArrowFFIExporter-$exporterId")
     thread.setDaemon(true)
     thread.setUncaughtExceptionHandler(new UncaughtExceptionHandler {
       override def uncaughtException(t: Thread, e: Throwable): Unit = {