[pulsar] 05/14: [Flaky-test]: AdminApiTest.testNamespaceSplitBundleConcurrent (#14565)

[penghui]

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 <lofterzh...@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]);
         }