diff --git a/java/e2e-v4/src/test/java/org/apache/rocketmq/client/message/NormalMessageSizeTest.java b/java/e2e-v4/src/test/java/org/apache/rocketmq/client/message/NormalMessageSizeTest.java
index e737fe9..6870cfb 100644
--- a/java/e2e-v4/src/test/java/org/apache/rocketmq/client/message/NormalMessageSizeTest.java
+++ b/java/e2e-v4/src/test/java/org/apache/rocketmq/client/message/NormalMessageSizeTest.java
@@ -282,7 +282,8 @@ public void testFifoMsgSize4M() {
         try {
             messageQueues = producer.fetchPublishMessageQueues(fifoTopic);
         } catch (MQClientException e) {
-            Assertions.assertNotNull(messageQueues);
+            log.info("Fetch publish message queues failed, {}", e.getMessage());
+//            Assertions.assertNotNull(messageQueues);
         }
         String orderId = "biz_" + 0;
         String messageBody = RandomStringUtils.randomAlphabetic(4 * 1024 * 1024);
diff --git a/java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/MessageTagTest.java b/java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/MessageTagTest.java
index 594a1e0..bf151db 100644
--- a/java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/MessageTagTest.java
+++ b/java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/MessageTagTest.java
@@ -137,7 +137,7 @@ public void testMessageTagContentWithChinese() {
 
         pushConsumer = ConsumerFactory.getRMQPushConsumer(account, topic, groupId, new FilterExpression(tag), new RMQNormalListener());
         simpleConsumer = ConsumerFactory.getRMQSimpleConsumer(account, topic, groupId, new FilterExpression(tag), Duration.ofSeconds(10));
-        VerifyUtils.tryReceiveOnce(simpleConsumer.getSimpleConsumer());
+//        VerifyUtils.tryReceiveOnce(simpleConsumer.getSimpleConsumer());
 
         producer = ProducerFactory.getRMQProducer(account, topic);
 
diff --git a/java/e2e/src/test/java/org/apache/rocketmq/broker/server/DelayMessageTest.java b/java/e2e/src/test/java/org/apache/rocketmq/broker/server/DelayMessageTest.java
index 29a3a41..255e60f 100644
--- a/java/e2e/src/test/java/org/apache/rocketmq/broker/server/DelayMessageTest.java
+++ b/java/e2e/src/test/java/org/apache/rocketmq/broker/server/DelayMessageTest.java
@@ -101,7 +101,7 @@ public void testDelay_Send_PushConsume() {
             producer.send(message);
         }
         Assertions.assertEquals(SEND_NUM, producer.getEnqueueMessages().getDataSize(), "send message failed");
-        VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 10);
+        VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 20);
     }
 
     @Test
@@ -129,7 +129,7 @@ public Boolean call() throws Exception {
             }
         });
         Assertions.assertEquals(SEND_NUM, producer.getEnqueueMessages().getDataSize(), "send message failed");
-        VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 10);
+        VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 20);
     }
 
     @Test
@@ -151,7 +151,7 @@ public void testDelayTime15SecondsAgo() {
             producer.send(message);
         }
         Assertions.assertEquals(SEND_NUM, producer.getEnqueueMessages().getDataSize(), "send message failed");
-        VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 0);
+        VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 5);
     }
 
     @Test
diff --git a/java/e2e/src/test/java/org/apache/rocketmq/broker/server/NormalMessageTest.java b/java/e2e/src/test/java/org/apache/rocketmq/broker/server/NormalMessageTest.java
index ba17313..08d48f7 100644
--- a/java/e2e/src/test/java/org/apache/rocketmq/broker/server/NormalMessageTest.java
+++ b/java/e2e/src/test/java/org/apache/rocketmq/broker/server/NormalMessageTest.java
@@ -103,7 +103,7 @@ public void testNormal_SendAsync_PushConsume() {
         String groupId = getGroupId(methodName);
         pushConsumer = ConsumerFactory.getRMQPushConsumer(account, topic, groupId, new FilterExpression(tag), new RMQNormalListener());
         simpleConsumer = ConsumerFactory.getRMQSimpleConsumer(account, topic, groupId, new FilterExpression(tag), Duration.ofSeconds(10));
-        VerifyUtils.tryReceiveOnce(simpleConsumer.getSimpleConsumer());
+//        VerifyUtils.tryReceiveOnce(simpleConsumer.getSimpleConsumer());
 
         producer = ProducerFactory.getRMQProducer(account, topic);
         Assertions.assertNotNull(producer, "Get Producer failed");
diff --git a/java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java b/java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java
index 702cbd0..f20ab80 100644
--- a/java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java
+++ b/java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java
@@ -116,7 +116,7 @@ public void test_waitAckException_reReceive_ack() {
         String topic = getTopic(TopicMessageType.NORMAL.getValue(), methodName);
         String groupId = getGroupId(methodName);
 
-        SimpleConsumer consumer = ConsumerFactory.getSimpleConsumer(account, topic, groupId, new FilterExpression(tag), Duration.ofSeconds(10));
+        SimpleConsumer consumer = ConsumerFactory.getSimpleConsumer(account, topic, groupId, new FilterExpression(tag), Duration.ofSeconds(5));
 //        VerifyUtils.tryReceiveOnce(consumer);
         RMQNormalProducer producer = ProducerFactory.getRMQProducer(account, topic);
         Assertions.assertNotNull(producer, "Get Producer failed");