diff --git a/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskResponseServiceTest.java b/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskResponseServiceTest.java
index c67f477b6d..584371d379 100644
--- a/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskResponseServiceTest.java
+++ b/dolphinscheduler-server/src/test/java/org/apache/dolphinscheduler/server/master/processor/queue/TaskResponseServiceTest.java
@@ -93,10 +93,8 @@ public class TaskResponseServiceTest {
 
         long maxWaitTime = 3 * 60 * 1000;
 
-        while (System.currentTimeMillis() - maxWaitTime - startTime < 0) {
-            if (taskResponseService.getEventQueue().size() == 0) {
-                return;
-            }
+        while (taskResponseService.getEventQueue().size() != 0) {
+
         }
 
         Assert.assertEquals(0, taskResponseService.getEventQueue().size());