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 56a7761..51d2949 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
@@ -45,7 +45,6 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.time.Duration;
 import java.util.concurrent.Callable;
 
 import static java.util.concurrent.TimeUnit.SECONDS;
@@ -101,7 +100,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(), 20);
+        VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 10);
     }
 
     @Test
@@ -129,7 +128,7 @@ public Boolean call() throws Exception {
             }
         });
         Assertions.assertEquals(SEND_NUM, producer.getEnqueueMessages().getDataSize(), "send message failed");
-        VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 20);
+        VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 10);
     }
 
     @Test