(pulsar) branch branch-3.0 updated: [fix][test]: Flaky-test: GetPartitionMetadataMultiBrokerTest.testCompatibilityDifferentBrokersForNonPersistentTopic (#23666)

[lhotari]

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

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


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new 36752e962b7 [fix][test]: Flaky-test: 
GetPartitionMetadataMultiBrokerTest.testCompatibilityDifferentBrokersForNonPersistentTopic
 (#23666)
36752e962b7 is described below

commit 36752e962b74a5c027a8a6c4e9a91060a0f9b887
Author: VisionXu <vis...@outlook.com>
AuthorDate: Fri Jan 3 16:42:02 2025 +0800

    [fix][test]: Flaky-test: 
GetPartitionMetadataMultiBrokerTest.testCompatibilityDifferentBrokersForNonPersistentTopic
 (#23666)
    
    (cherry picked from commit 1cdb5db8400025590fc87124241f4fafcf6e5981)
---
 .../pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java   | 7 ++++---
 1 file changed, 4 insertions(+), 3 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 d1eeabdb3d7..1b4732f69d4 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
@@ -253,6 +253,10 @@ public class GetPartitionMetadataMultiBrokerTest extends 
GetPartitionMetadataTes
                                                   boolean isUsingHttpLookup) 
throws Exception {
         modifyTopicAutoCreation(configAllowAutoTopicCreation, 
TopicType.PARTITIONED, 3);
 
+        // Verify: the method "getPartitionsForTopic(topic, false, true)" will 
fallback
+        //   to "getPartitionsForTopic(topic, true)" behavior.
+        int lookupPermitsBefore = getLookupRequestPermits();
+
         // Initialize the connections of internal Pulsar Client.
         PulsarClientImpl client1 = (PulsarClientImpl) pulsar1.getClient();
         PulsarClientImpl client2 = (PulsarClientImpl) pulsar2.getClient();
@@ -270,9 +274,6 @@ public class GetPartitionMetadataMultiBrokerTest extends 
GetPartitionMetadataTes
                 field.set(clientCnx, false);
             }
         }
-        // Verify: the method "getPartitionsForTopic(topic, false, true)" will 
fallback
-        //   to "getPartitionsForTopic(topic, true)" behavior.
-        int lookupPermitsBefore = getLookupRequestPermits();
 
         // Verify: we will not get an un-support error.
         PulsarClientImpl[] clientArray = getClientsToTest(isUsingHttpLookup);