From 3ee603a49b04c0b602ff8eb45b3ef4330293fba8 Mon Sep 17 00:00:00 2001
From: rongtong <jinrongtong5@163.com>
Date: Mon, 18 Jul 2022 09:19:43 +0800
Subject: [PATCH] Try to make CI test more stable (#4616)

---
 .../rocketmq/test/statictopic/StaticTopicIT.java       | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/test/src/test/java/org/apache/rocketmq/test/statictopic/StaticTopicIT.java b/test/src/test/java/org/apache/rocketmq/test/statictopic/StaticTopicIT.java
index b198c7a7ac4..29b92d5f4ad 100644
--- a/test/src/test/java/org/apache/rocketmq/test/statictopic/StaticTopicIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/statictopic/StaticTopicIT.java
@@ -108,7 +108,7 @@ public void testCommandsWithBrokers() throws Exception {
         RMQNormalProducer producer = getProducer(nsAddr, topic);
         RMQNormalConsumer consumer = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
         int queueNum = 10;
-        int msgEachQueue = 100;
+        int msgEachQueue = 10;
         {
             Set<String> brokers = ImmutableSet.of(broker1Name);
             MQAdminTestUtils.createStaticTopicWithCommand(topic, queueNum, brokers, null, nsAddr);
@@ -207,7 +207,7 @@ public int compare(MessageExt o1, MessageExt o2) {
     }
 
     private void consumeMessagesAndCheck(RMQNormalProducer producer, RMQNormalConsumer consumer, String topic, int queueNum, int msgEachQueue, int startGen, int genNum) {
-        consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), 30000);
+        consumer.getListener().waitForMessageConsume(producer.getAllMsgBody(), 60000);
 //        System.out.println("produce:" + producer.getAllMsgBody().size());
 //        System.out.println("consume:" + consumer.getListener().getAllMsgBody().size());
 
@@ -243,7 +243,7 @@ public void testCreateProduceConsumeStaticTopic() throws Exception {
         RMQNormalConsumer consumer = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
 
         int queueNum = 10;
-        int msgEachQueue = 100;
+        int msgEachQueue = 10;
         //create static topic
         Map<String, TopicConfigAndQueueMapping> localBrokerConfigMap = MQAdminTestUtils.createStaticTopic(topic, queueNum, getBrokers(), defaultMQAdminExt);
         //check the static topic config
@@ -275,7 +275,7 @@ public void testRemappingProduceConsumeStaticTopic() throws Exception {
         RMQNormalConsumer consumer = getConsumer(nsAddr, topic, "*", new RMQNormalListener());
 
         int queueNum = 1;
-        int msgEachQueue = 100;
+        int msgEachQueue = 10;
         //create send consume
         {
             Set<String> targetBrokers = ImmutableSet.of(broker1Name);
@@ -346,7 +346,7 @@ public void testDoubleReadCheckConsumerOffset() throws Exception {
         long start = System.currentTimeMillis();
 
         int queueNum = 10;
-        int msgEachQueue = 100;
+        int msgEachQueue = 10;
         //create static topic
         {
             Set<String> targetBrokers = ImmutableSet.of(broker1Name);