From 1269322040b8d48bf34d8616b2ecbbfa0b1a604f Mon Sep 17 00:00:00 2001 From: SSpirits Date: Wed, 13 Dec 2023 06:15:48 +0000 Subject: [PATCH] disable some tests in LoadBalancingTest --- .../java/org/apache/rocketmq/cluster/LoadBalancingTest.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/java/e2e-v4/src/test/java/org/apache/rocketmq/cluster/LoadBalancingTest.java b/java/e2e-v4/src/test/java/org/apache/rocketmq/cluster/LoadBalancingTest.java index 361cab9..46930ee 100644 --- a/java/e2e-v4/src/test/java/org/apache/rocketmq/cluster/LoadBalancingTest.java +++ b/java/e2e-v4/src/test/java/org/apache/rocketmq/cluster/LoadBalancingTest.java @@ -52,6 +52,7 @@ import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Tag; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -165,6 +166,7 @@ public Boolean call() throws Exception { consumer6.shutdown(); } + @Disabled @Test @DisplayName("Global sequential message load balancing: Start 2 consumers, send 30 messages, expect only 1 Consumer to consume the message, and the other Consumer to consume 0, then shutdown 1 Consumer with message consumption, send another 30 messages, expect the idling Consumer to pull the message") public void testLoadBalancing_global_sequential_message(){ @@ -218,6 +220,7 @@ public Boolean call() throws Exception { consumer2.shutdown(); } + @Disabled @Test @DisplayName("Partition sequential message load balancing, start 4 consumers, send 120 messages, shardingkey=8, expect 4 consumers to consume load balancing, each consumes 1/4 Partition, shutdown 2 of the consumers, send 120 messages again. The load is still balanced, and half of each Partition is consumed") public void testLoadBalancing_partition_sequential_message(){