From a164d5f990c988cac7b45a2952f4d6eee5d17e44 Mon Sep 17 00:00:00 2001
From: CalvinKirs <acm_master@163.com>
Date: Wed, 25 Nov 2020 10:23:54 +0800
Subject: [PATCH] Time is too small and the task is not finished

---
 .../processor/queue/TaskResponseServiceTest.java       | 10 +++++-----
 1 file changed, 5 insertions(+), 5 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 969618a9b2..d60c9c192c 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
@@ -84,15 +84,15 @@ public class TaskResponseServiceTest {
         Mockito.when(channel.writeAndFlush(Mockito.any())).thenReturn(null);
         taskResponseService.addResponse(ackEvent);
         taskResponseService.addResponse(resultEvent);
-        try {
-            Thread.sleep(10000);
-        } catch (InterruptedException ignored) {
-            Thread.currentThread().interrupt();
-        }
     }
 
     @After
     public void after() {
+        try {
+            Thread.sleep(20000);
+        } catch (InterruptedException ignored) {
+            Thread.currentThread().interrupt();
+        }
         Assert.assertEquals(0, taskResponseService.getEventQueue().size());
         taskResponseService.stop();
     }