From 03f409391dda603122dfeeb7e0a612016b2cb66a Mon Sep 17 00:00:00 2001 From: Rong Ma Date: Fri, 18 Sep 2026 11:32:58 +0100 Subject: [PATCH] remove registered executors --- .../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 1fe8d2a2c12..3afae9fabf3 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) } }