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 3d5dc0c87b..969618a9b2 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 @@ -85,7 +85,7 @@ public class TaskResponseServiceTest { taskResponseService.addResponse(ackEvent); taskResponseService.addResponse(resultEvent); try { - Thread.sleep(1000); + Thread.sleep(10000); } catch (InterruptedException ignored) { Thread.currentThread().interrupt(); }