[fix][test] Fix flaky LookupPropertiesTest.testConcurrentLookupProperties (apache#24854)

pdolif · manas-ctds · commit a25a96a86916 · 2025-10-29T11:52:17.000+05:30
(cherry picked from commit d743278) (cherry picked from commit 324fadd)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/LookupPropertiesTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/LookupPropertiesTest.java
@@ -18,6 +18,7 @@
  */
 package org.apache.pulsar.client.api;
 
+import static org.assertj.core.api.Assertions.assertThat;
 import java.net.InetSocketAddress;
 import java.util.ArrayList;
 import java.util.Collections;
@@ -112,7 +113,7 @@ public void testConcurrentLookupProperties() throws Exception {
             client.getConfiguration().setLookupProperties(Collections.emptyMap());
         }
         FutureUtil.waitForAll(futures).get();
-        Assert.assertEquals(clientIdList, BrokerIdAwareLoadManager.CLIENT_ID_LIST);
+        assertThat(BrokerIdAwareLoadManager.CLIENT_ID_LIST).containsExactlyInAnyOrderElementsOf(clientIdList);
     }
 
     public static class BrokerIdAwareLoadManager extends ExtensibleLoadManagerImpl {

Original file line number	Diff line number	Diff line change
`@@ -18,6 +18,7 @@`
`18`	`18`	`*/`
`19`	`19`	`package org.apache.pulsar.client.api;`
`20`	`20`
	`21`	`+import static org.assertj.core.api.Assertions.assertThat;`
`21`	`22`	`import java.net.InetSocketAddress;`
`22`	`23`	`import java.util.ArrayList;`
`23`	`24`	`import java.util.Collections;`
`@@ -112,7 +113,7 @@ public void testConcurrentLookupProperties() throws Exception {`
`112`	`113`	`client.getConfiguration().setLookupProperties(Collections.emptyMap());`
`113`	`114`	`}`
`114`	`115`	`FutureUtil.waitForAll(futures).get();`
`115`		`- Assert.assertEquals(clientIdList, BrokerIdAwareLoadManager.CLIENT_ID_LIST);`
	`116`	`+ assertThat(BrokerIdAwareLoadManager.CLIENT_ID_LIST).containsExactlyInAnyOrderElementsOf(clientIdList);`
`116`	`117`	`}`
`117`	`118`
`118`	`119`	`public static class BrokerIdAwareLoadManager extends ExtensibleLoadManagerImpl {`