(pulsar) branch master updated: [fix][test] Fix flaky GetPartitionMetadataMultiBrokerTest.testCompatibilityDifferentBrokersForNonPersistentTopic (#23259)

[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 c891eaa38a0 [fix][test] Fix flaky 
GetPartitionMetadataMultiBrokerTest.testCompatibilityDifferentBrokersForNonPersistentTopic
 (#23259)
c891eaa38a0 is described below

commit c891eaa38a02dbbdb855b5d5d1de609f1ceb6132
Author: hanmz <gunn...@tencent.com>
AuthorDate: Wed Oct 9 22:46:47 2024 +0800

    [fix][test] Fix flaky 
GetPartitionMetadataMultiBrokerTest.testCompatibilityDifferentBrokersForNonPersistentTopic
 (#23259)
---
 .../pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java
index 60691203e77..d1eeabdb3d7 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java
@@ -256,8 +256,8 @@ public class GetPartitionMetadataMultiBrokerTest extends 
GetPartitionMetadataTes
         // Initialize the connections of internal Pulsar Client.
         PulsarClientImpl client1 = (PulsarClientImpl) pulsar1.getClient();
         PulsarClientImpl client2 = (PulsarClientImpl) pulsar2.getClient();
-        
client1.getLookup(pulsar2.getBrokerServiceUrl()).getBroker(TopicName.get(DEFAULT_NS
 + "/tp1"));
-        
client2.getLookup(pulsar1.getBrokerServiceUrl()).getBroker(TopicName.get(DEFAULT_NS
 + "/tp1"));
+        
client1.getLookup(pulsar2.getBrokerServiceUrl()).getBroker(TopicName.get(DEFAULT_NS
 + "/tp1")).join();
+        
client2.getLookup(pulsar1.getBrokerServiceUrl()).getBroker(TopicName.get(DEFAULT_NS
 + "/tp1")).join();
 
         // Inject a not support flag into the connections initialized.
         Field field = 
ClientCnx.class.getDeclaredField("supportsGetPartitionedMetadataWithoutAutoCreation");