From 2a9e789f68d6aba2bdd8a8073ac0abb4b36cd51e Mon Sep 17 00:00:00 2001
From: CalvinKirs <acm_master@163.com>
Date: Wed, 25 Nov 2020 14:47:00 +0800
Subject: [PATCH] test

---
 .../master/processor/queue/TaskResponseServiceTest.java     | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

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());