[fix][build] Disable flaky test BrokerRegistryIntegrationTest (apache…

…#23367)
Technoboy- · Sep 28, 2024 · ca4a743 · ca4a743
1 parent 95bd1d1
commit ca4a743
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...t/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java b/...t/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java
@@ -37,7 +37,7 @@
 import org.testng.annotations.Test;
 
 @Slf4j
-@Test(groups = "broker")
+@Test(groups = "flaky")
 public class BrokerRegistryIntegrationTest {
 
     private static final String clusterName = "test";
@@ -69,7 +69,7 @@ protected void cleanup() throws Exception {
         bk.stop();
     }
 
-    @Test
+    @Test(enabled = false)
     public void testRecoverFromNodeDeletion() throws Exception {
         // Simulate the case that the node was somehow deleted (e.g. by session timeout)
         Awaitility.await().atMost(Duration.ofSeconds(3)).untilAsserted(() -> Assert.assertEquals(
@@ -88,7 +88,7 @@ public void testRecoverFromNodeDeletion() throws Exception {
         Assert.assertEquals(brokerRegistry.getAvailableBrokersAsync().get(), List.of(pulsar.getBrokerId()));
     }
 
-    @Test
+    @Test(enabled = false)
     public void testRegisterAgain() throws Exception {
         Awaitility.await().atMost(Duration.ofSeconds(3)).untilAsserted(() -> Assert.assertEquals(
                 brokerRegistry.getAvailableBrokersAsync().join(), List.of(pulsar.getBrokerId())));