From c69af46cd31924a744e48174e5d431fea1dba974 Mon Sep 17 00:00:00 2001 From: Haiyang Sun Date: Fri, 4 Sep 2026 13:26:12 +0000 Subject: [PATCH] [SPARK-59253][UDF] Fix direct dispatcher interrupt race Capture and clear an interrupt that races with lifecycle notification so dispatcher cleanup completes before close restores the interrupt status. --- .../spark/udf/worker/core/direct/DirectWorkerDispatcher.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/udf/worker/core/src/main/scala/org/apache/spark/udf/worker/core/direct/DirectWorkerDispatcher.scala b/udf/worker/core/src/main/scala/org/apache/spark/udf/worker/core/direct/DirectWorkerDispatcher.scala index dd880a620467..7d7d23b66830 100644 --- a/udf/worker/core/src/main/scala/org/apache/spark/udf/worker/core/direct/DirectWorkerDispatcher.scala +++ b/udf/worker/core/src/main/scala/org/apache/spark/udf/worker/core/direct/DirectWorkerDispatcher.scala @@ -356,6 +356,7 @@ abstract class DirectWorkerDispatcher( } } } + interrupted = Thread.interrupted() || interrupted interrupted }