(pulsar) branch master updated: [fix][build] Disable flaky test BrokerRegistryIntegrationTest (#23367)

[mm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new ca4a7435db6 [fix][build] Disable flaky test BrokerRegistryIntegrationTest (#23367)
ca4a7435db6 is described below

commit ca4a7435db6a99560284324b470ff66cae9d84f5
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Sat Sep 28 20:10:54 2024 +0300

    [fix][build] Disable flaky test BrokerRegistryIntegrationTest (#23367)
---
 .../loadbalance/extensions/BrokerRegistryIntegrationTest.java       | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java
index 162ea50829d..d6615a8a5b4 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryIntegrationTest.java
@@ -37,7 +37,7 @@ import org.testng.annotations.BeforeClass;
 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 @@ public class BrokerRegistryIntegrationTest {
         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 class BrokerRegistryIntegrationTest {
         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())));