You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/03/12 02:40:58 UTC
[pulsar] 05/14: [Flaky-test]: AdminApiTest.testNamespaceSplitBundleConcurrent (#14565)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 5228c908d7d05ed0ea49c23a74ea3a64b63e7222
Author: Aloys <lo...@gmail.com>
AuthorDate: Sat Mar 5 18:29:52 2022 +0800
[Flaky-test]: AdminApiTest.testNamespaceSplitBundleConcurrent (#14565)
(cherry picked from commit 01b55678321b6cf254f5d289f7eb177a6aea9be9)
---
.../src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
index 672bf96..c10f342 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApiTest.java
@@ -1533,10 +1533,11 @@ public class AdminApiTest extends MockedPulsarServiceBaseTest {
fail("split bundle shouldn't have thrown exception");
}
+ Awaitility.await().untilAsserted(() ->
+ assertEquals(bundleFactory.getBundles(NamespaceName.get(namespace)).getBundles().size(), 4));
String[] splitRange4 = { namespace + "/0x00000000_0x3fffffff", namespace + "/0x3fffffff_0x7fffffff",
namespace + "/0x7fffffff_0xbfffffff", namespace + "/0xbfffffff_0xffffffff" };
bundles = bundleFactory.getBundles(NamespaceName.get(namespace));
- assertEquals(bundles.getBundles().size(), 4);
for (int i = 0; i < bundles.getBundles().size(); i++) {
assertEquals(bundles.getBundles().get(i).toString(), splitRange4[i]);
}
@@ -1566,13 +1567,13 @@ public class AdminApiTest extends MockedPulsarServiceBaseTest {
} catch (Exception e) {
fail("split bundle shouldn't have thrown exception");
}
-
+ Awaitility.await().untilAsserted(() ->
+ assertEquals(bundleFactory.getBundles(NamespaceName.get(namespace)).getBundles().size(), 8));
String[] splitRange8 = { namespace + "/0x00000000_0x1fffffff", namespace + "/0x1fffffff_0x3fffffff",
namespace + "/0x3fffffff_0x5fffffff", namespace + "/0x5fffffff_0x7fffffff",
namespace + "/0x7fffffff_0x9fffffff", namespace + "/0x9fffffff_0xbfffffff",
namespace + "/0xbfffffff_0xdfffffff", namespace + "/0xdfffffff_0xffffffff" };
bundles = bundleFactory.getBundles(NamespaceName.get(namespace));
- assertEquals(bundles.getBundles().size(), 8);
for (int i = 0; i < bundles.getBundles().size(); i++) {
assertEquals(bundles.getBundles().get(i).toString(), splitRange8[i]);
}