(pulsar) branch master updated: [fix][test] Fix flaky testGetExcludedBookiesWithIsolationGroups (#25640)

[lhotari]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 6edd35defd2 [fix][test] Fix flaky 
testGetExcludedBookiesWithIsolationGroups (#25640)
6edd35defd2 is described below

commit 6edd35defd2bc78c943b0542b210d394ec3b8690
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Fri May 1 06:09:54 2026 -0700

    [fix][test] Fix flaky testGetExcludedBookiesWithIsolationGroups (#25640)
---
 .../rackawareness/IsolatedBookieEnsemblePlacementPolicyTest.java   | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/pulsar-broker-common/src/test/java/org/apache/pulsar/bookie/rackawareness/IsolatedBookieEnsemblePlacementPolicyTest.java
 
b/pulsar-broker-common/src/test/java/org/apache/pulsar/bookie/rackawareness/IsolatedBookieEnsemblePlacementPolicyTest.java
index c564ed3ffcf..7940ccc636b 100644
--- 
a/pulsar-broker-common/src/test/java/org/apache/pulsar/bookie/rackawareness/IsolatedBookieEnsemblePlacementPolicyTest.java
+++ 
b/pulsar-broker-common/src/test/java/org/apache/pulsar/bookie/rackawareness/IsolatedBookieEnsemblePlacementPolicyTest.java
@@ -746,6 +746,13 @@ public class IsolatedBookieEnsemblePlacementPolicyTest {
                 NullStatsLogger.INSTANCE, 
BookieSocketAddress.LEGACY_BOOKIEID_RESOLVER);
         isolationPolicy.onClusterChanged(writableBookies, readOnlyBookies);
 
+        // Wait for the async cache load triggered by initialize() to 
complete; otherwise
+        // getExcludedBookiesWithIsolationGroups returns an empty set when 
cachedRackConfiguration
+        // is still null. Same pattern used in testBookieInfoChange (#25473).
+        Awaitility.await().atMost(Duration.ofSeconds(5)).untilAsserted(() ->
+                assertNotNull(isolationPolicy.getBookieMappingCache()
+                        
.getIfCached(BookieRackAffinityMapping.BOOKIE_INFO_ROOT_PATH)));
+
         /* Test common cases */
         MutablePair<Set<String>, Set<String>> groups = new MutablePair<>();
         groups.setLeft(Sets.newHashSet(isolationGroup1));