Skip to content

Commit

Permalink
[fix][flaky-test] testSplitBundleForMultiTimes (#16562)
Browse files Browse the repository at this point in the history
(cherry picked from commit 2018595)
  • Loading branch information
gaozhangmin authored and Jason918 committed Sep 2, 2022
1 parent 5d2c985 commit aa10f5d
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1750,6 +1750,9 @@ public void testSplitBundleForMultiTimes() throws Exception{
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);
Expand Down

0 comments on commit aa10f5d

Please sign in to comment.