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 1e3b0d181d..a9eca5106c 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 0fe08e879d..4c0674e437 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 8e0abd2469..11d1346570 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 540c0723ec..f42146b271 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 0181645b36..94e056aeda 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 abe1d5e81e..9179d1ef23 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 41345b1633..2b03301723 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 6e5c9a97cb..617d72233a 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 ea35781f63..a2d86d4366 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 3e6cd8dfbb..e6449c9ee0 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 7b243f5fcb..a562257224 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";