You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ji...@apache.org on 2022/09/02 03:16:33 UTC
[pulsar] 01/04: [fix][flaky-test] testSplitBundleForMultiTimes (#16562)
This is an automated email from the ASF dual-hosted git repository.
jianghaiting pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit aa10f5dff0bf6a661d4940fd4686f1667d26bbb6
Author: gaozhangmin <zh...@apache.org>
AuthorDate: Mon Aug 15 21:08:28 2022 +0800
[fix][flaky-test] testSplitBundleForMultiTimes (#16562)
(cherry picked from commit 20185951422fe2a2cebec8a2537d7a9257212644)
---
.../src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
index cd9fef4b34c..b754a592ba0 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
@@ -1750,6 +1750,9 @@ public class NamespacesTest extends MockedPulsarServiceBaseTest {
String namespace = BrokerTestUtil.newUniqueName(this.testTenant + "/namespace");
BundlesData data = BundlesData.builder().numBundles(4).build();
admin.namespaces().createNamespace(namespace, data);
+ URL localWebServiceUrl = new URL(pulsar.getSafeWebServiceAddress());
+ final NamespaceName testNs = NamespaceName.get(namespace);
+ mockWebUrl(localWebServiceUrl, testNs);
for (int i = 0; i < 10; i ++) {
final BundlesData bundles = admin.namespaces().getBundles(namespace);
final String bundle = bundles.getBoundaries().get(0) + "_" + bundles.getBoundaries().get(1);