You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/03/18 15:14:00 UTC

[rocketmq] branch 5.0.0-beta-tmp updated: Ignore all container tests because they cost too much time and are unstable

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

jinrongtong pushed a commit to branch 5.0.0-beta-tmp
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/5.0.0-beta-tmp by this push:
     new a44699a  Ignore all container tests because they cost too much time and are unstable
a44699a is described below

commit a44699acd6eafe09e8d78d5c9fecded62134dcdf
Author: RongtongJin <ji...@mails.ucas.ac.cn>
AuthorDate: Fri Mar 18 23:13:35 2022 +0800

    Ignore all container tests because they cost too much time and are unstable
---
 .../java/org/apache/rocketmq/test/container/AddAndRemoveBrokerIT.java  | 3 ++-
 .../test/java/org/apache/rocketmq/test/container/BrokerFailoverIT.java | 3 ++-
 .../java/org/apache/rocketmq/test/container/BrokerMemberGroupIT.java   | 3 ++-
 .../org/apache/rocketmq/test/container/GetMaxOffsetFromSlaveIT.java    | 3 ++-
 .../org/apache/rocketmq/test/container/PullMultipleReplicasIT.java     | 2 ++
 .../org/apache/rocketmq/test/container/PushMultipleReplicasIT.java     | 2 ++
 .../org/apache/rocketmq/test/container/RebalanceLockOnSlaveIT.java     | 1 +
 .../java/org/apache/rocketmq/test/container/ScheduledMessageIT.java    | 1 +
 .../org/apache/rocketmq/test/container/SendMultipleReplicasIT.java     | 2 ++
 .../test/java/org/apache/rocketmq/test/container/SlaveBrokerIT.java    | 2 ++
 .../java/org/apache/rocketmq/test/container/SyncConsumerOffsetIT.java  | 2 ++
 11 files changed, 20 insertions(+), 4 deletions(-)

diff --git a/test/src/test/java/org/apache/rocketmq/test/container/AddAndRemoveBrokerIT.java b/test/src/test/java/org/apache/rocketmq/test/container/AddAndRemoveBrokerIT.java
index 1e3b0d1..a9eca51 100644
--- a/test/src/test/java/org/apache/rocketmq/test/container/AddAndRemoveBrokerIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/container/AddAndRemoveBrokerIT.java
@@ -25,11 +25,12 @@ import org.apache.rocketmq.remoting.exception.RemotingSendRequestException;
 import org.apache.rocketmq.remoting.exception.RemotingTimeoutException;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
-
+@Ignore
 public class AddAndRemoveBrokerIT extends ContainerIntegrationTestBase {
     private static BrokerContainer brokerContainer4;
 
diff --git a/test/src/test/java/org/apache/rocketmq/test/container/BrokerFailoverIT.java b/test/src/test/java/org/apache/rocketmq/test/container/BrokerFailoverIT.java
index 0fe08e8..4c0674e 100644
--- a/test/src/test/java/org/apache/rocketmq/test/container/BrokerFailoverIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/container/BrokerFailoverIT.java
@@ -22,12 +22,13 @@ import org.apache.rocketmq.container.InnerSalveBrokerController;
 import org.apache.rocketmq.common.protocol.RequestCode;
 import org.apache.rocketmq.remoting.RPCHook;
 import org.apache.rocketmq.remoting.protocol.RemotingCommand;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
 
-
+@Ignore
 public class BrokerFailoverIT extends ContainerIntegrationTestBase {
 
     @Test
diff --git a/test/src/test/java/org/apache/rocketmq/test/container/BrokerMemberGroupIT.java b/test/src/test/java/org/apache/rocketmq/test/container/BrokerMemberGroupIT.java
index 8e0abd2..11d1346 100644
--- a/test/src/test/java/org/apache/rocketmq/test/container/BrokerMemberGroupIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/container/BrokerMemberGroupIT.java
@@ -20,11 +20,12 @@ package org.apache.rocketmq.test.container;
 import java.time.Duration;
 import org.apache.rocketmq.common.BrokerConfig;
 import org.apache.rocketmq.common.protocol.body.BrokerMemberGroup;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import static org.awaitility.Awaitility.await;
 
-
+@Ignore
 public class BrokerMemberGroupIT extends ContainerIntegrationTestBase {
     @Test
     public void testSyncBrokerMemberGroup() throws Exception {
diff --git a/test/src/test/java/org/apache/rocketmq/test/container/GetMaxOffsetFromSlaveIT.java b/test/src/test/java/org/apache/rocketmq/test/container/GetMaxOffsetFromSlaveIT.java
index 540c072..f42146b 100644
--- a/test/src/test/java/org/apache/rocketmq/test/container/GetMaxOffsetFromSlaveIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/container/GetMaxOffsetFromSlaveIT.java
@@ -34,12 +34,13 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
 import org.apache.rocketmq.store.DefaultMessageStore;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import static org.assertj.core.api.Java6Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
 
-
+@Ignore
 public class GetMaxOffsetFromSlaveIT extends ContainerIntegrationTestBase {
     private static DefaultMQProducer mqProducer;
 
diff --git a/test/src/test/java/org/apache/rocketmq/test/container/PullMultipleReplicasIT.java b/test/src/test/java/org/apache/rocketmq/test/container/PullMultipleReplicasIT.java
index 0181645..94e056a 100644
--- a/test/src/test/java/org/apache/rocketmq/test/container/PullMultipleReplicasIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/container/PullMultipleReplicasIT.java
@@ -44,11 +44,13 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
 import org.apache.rocketmq.store.DefaultMessageStore;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import static org.assertj.core.api.Java6Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
 
+@Ignore
 public class PullMultipleReplicasIT extends ContainerIntegrationTestBase {
     private static DefaultMQPullConsumer pullConsumer;
     private static DefaultMQProducer producer;
diff --git a/test/src/test/java/org/apache/rocketmq/test/container/PushMultipleReplicasIT.java b/test/src/test/java/org/apache/rocketmq/test/container/PushMultipleReplicasIT.java
index abe1d5e..9179d1e 100644
--- a/test/src/test/java/org/apache/rocketmq/test/container/PushMultipleReplicasIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/container/PushMultipleReplicasIT.java
@@ -31,10 +31,12 @@ import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
 import org.apache.rocketmq.common.message.Message;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import static org.awaitility.Awaitility.await;
 
+@Ignore
 public class PushMultipleReplicasIT extends ContainerIntegrationTestBase {
     private static DefaultMQProducer producer;
 
diff --git a/test/src/test/java/org/apache/rocketmq/test/container/RebalanceLockOnSlaveIT.java b/test/src/test/java/org/apache/rocketmq/test/container/RebalanceLockOnSlaveIT.java
index 41345b1..2b03301 100644
--- a/test/src/test/java/org/apache/rocketmq/test/container/RebalanceLockOnSlaveIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/container/RebalanceLockOnSlaveIT.java
@@ -43,6 +43,7 @@ import static org.awaitility.Awaitility.await;
 /**
  * Test lock on slave when acting master enabled
  */
+@Ignore
 public class RebalanceLockOnSlaveIT extends ContainerIntegrationTestBase {
     private static final String THREE_REPLICA_CONSUMER_GROUP = "SyncConsumerOffsetIT_ConsumerThreeReplica";
 
diff --git a/test/src/test/java/org/apache/rocketmq/test/container/ScheduledMessageIT.java b/test/src/test/java/org/apache/rocketmq/test/container/ScheduledMessageIT.java
index 6e5c9a9..617d722 100644
--- a/test/src/test/java/org/apache/rocketmq/test/container/ScheduledMessageIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/container/ScheduledMessageIT.java
@@ -41,6 +41,7 @@ import org.junit.Test;
 import static org.assertj.core.api.Java6Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
 
+@Ignore
 public class ScheduledMessageIT extends ContainerIntegrationTestBase {
     private static DefaultMQProducer producer;
 
diff --git a/test/src/test/java/org/apache/rocketmq/test/container/SendMultipleReplicasIT.java b/test/src/test/java/org/apache/rocketmq/test/container/SendMultipleReplicasIT.java
index ea35781..a2d86d4 100644
--- a/test/src/test/java/org/apache/rocketmq/test/container/SendMultipleReplicasIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/container/SendMultipleReplicasIT.java
@@ -32,11 +32,13 @@ import org.apache.rocketmq.remoting.exception.RemotingException;
 import org.apache.rocketmq.store.DefaultMessageStore;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import static org.assertj.core.api.Java6Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
 
+@Ignore
 public class SendMultipleReplicasIT extends ContainerIntegrationTestBase {
     private static DefaultMQProducer mqProducer;
 
diff --git a/test/src/test/java/org/apache/rocketmq/test/container/SlaveBrokerIT.java b/test/src/test/java/org/apache/rocketmq/test/container/SlaveBrokerIT.java
index 3e6cd8d..e6449c9 100644
--- a/test/src/test/java/org/apache/rocketmq/test/container/SlaveBrokerIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/container/SlaveBrokerIT.java
@@ -21,11 +21,13 @@ import java.time.Duration;
 import java.util.concurrent.TimeUnit;
 import org.apache.rocketmq.common.protocol.body.ClusterInfo;
 import org.apache.rocketmq.store.DefaultMessageStore;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
 
+@Ignore
 public class SlaveBrokerIT extends ContainerIntegrationTestBase {
     @Test
     public void reAddSlaveBroker() throws Exception {
diff --git a/test/src/test/java/org/apache/rocketmq/test/container/SyncConsumerOffsetIT.java b/test/src/test/java/org/apache/rocketmq/test/container/SyncConsumerOffsetIT.java
index 7b243f5..a562257 100644
--- a/test/src/test/java/org/apache/rocketmq/test/container/SyncConsumerOffsetIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/container/SyncConsumerOffsetIT.java
@@ -44,11 +44,13 @@ import org.apache.rocketmq.remoting.common.RemotingHelper;
 import org.apache.rocketmq.remoting.exception.RemotingException;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import static org.assertj.core.api.Java6Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
 
+@Ignore
 public class SyncConsumerOffsetIT extends ContainerIntegrationTestBase {
     private static final String THREE_REPLICA_CONSUMER_GROUP = "SyncConsumerOffsetIT_ConsumerThreeReplica";
     private static final String TEST_SYNC_TOPIC = SyncConsumerOffsetIT.class.getSimpleName() + "_topic";