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 584371d379..c8c5614bff 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 @@ -88,16 +88,6 @@ public class TaskResponseServiceTest { @After public void after() { - - long startTime = System.currentTimeMillis(); - - long maxWaitTime = 3 * 60 * 1000; - - while (taskResponseService.getEventQueue().size() != 0) { - - } - - Assert.assertEquals(0, taskResponseService.getEventQueue().size()); taskResponseService.stop(); }