Skip to content

Commit

Permalink
[fix][flaky-test] testSplitBundleForMultiTimes (apache#16562)
Browse files Browse the repository at this point in the history
  • Loading branch information
gaozhangmin authored Aug 15, 2022
1 parent 3cfca3f commit 2018595
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1829,6 +1829,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 2018595

Please sign in to comment.