You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2025/01/03 08:42:09 UTC
(pulsar) branch master updated: [fix][test]: Flaky-test: GetPartitionMetadataMultiBrokerTest.testCompatibilityDifferentBrokersForNonPersistentTopic (#23666)
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 1cdb5db8400 [fix][test]: Flaky-test: GetPartitionMetadataMultiBrokerTest.testCompatibilityDifferentBrokersForNonPersistentTopic (#23666)
1cdb5db8400 is described below
commit 1cdb5db8400025590fc87124241f4fafcf6e5981
Author: VisionXu <vi...@outlook.com>
AuthorDate: Fri Jan 3 16:42:02 2025 +0800
[fix][test]: Flaky-test: GetPartitionMetadataMultiBrokerTest.testCompatibilityDifferentBrokersForNonPersistentTopic (#23666)
---
.../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);