test

4 years ago · 2a9e789f68
1 changed files with 2 additions and 4 deletions
--- 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());