This is an automated email from the ASF dual-hosted git repository.
marin-ma pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 3a0c764033 [MINOR] [CORE] Remove registered executors in soft affinity
UT (#13054)
3a0c764033 is described below
commit 3a0c7640335c6ad3a061092486a0d3598b54b126
Author: Rong Ma <[email protected]>
AuthorDate: Mon Sep 21 09:26:25 2026 +0100
[MINOR] [CORE] Remove registered executors in soft affinity UT (#13054)
---
.../org/apache/spark/softaffinity/SoftAffinitySuite.scala | 11 +++++++++++
1 file changed, 11 insertions(+)
diff --git
a/gluten-substrait/src/test/scala/org/apache/spark/softaffinity/SoftAffinitySuite.scala
b/gluten-substrait/src/test/scala/org/apache/spark/softaffinity/SoftAffinitySuite.scala
index 1fe8d2a2c1..3afae9fabf 100644
---
a/gluten-substrait/src/test/scala/org/apache/spark/softaffinity/SoftAffinitySuite.scala
+++
b/gluten-substrait/src/test/scala/org/apache/spark/softaffinity/SoftAffinitySuite.scala
@@ -269,5 +269,16 @@ class SoftAffinitySuite extends QueryTest with
SharedSparkSession with Predicate
("3", "host-3"),
("4", "host-3"))
))
+
+ executorsListListener.onExecutorRemoved(removedEvent0)
+ executorsListListener.onExecutorRemoved(removedEvent1)
+ executorsListListener.onExecutorRemoved(removedEvent2)
+ executorsListListener.onExecutorRemoved(removedEvent3)
+ executorsListListener.onExecutorRemoved(removedEvent4)
+ executorsListListener.onExecutorRemoved(removedEvent5)
+ executorsListListener.onExecutorRemoved(removedEvent6)
+
+ assert(SoftAffinityManager.nodesExecutorsMap.isEmpty)
+ assert(SoftAffinityManager.sortedIdForExecutors.isEmpty)
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
