diff --git llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/TestTaskExecutorService.java llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/TestTaskExecutorService.java index ce9fce94de..49464159b8 100644 --- llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/TestTaskExecutorService.java +++ llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/TestTaskExecutorService.java @@ -512,6 +512,7 @@ public void testSetCapacity() throws InterruptedException { // Wait for a scheduling attempt, the new task should be started awaitStartAndSchedulerRun(r7, taskExecutorService); + awaitStartAndSchedulerRun(r4, taskExecutorService); assertEquals(0, taskExecutorService.waitQueue.size()); assertEquals(0, taskExecutorService.numSlotsAvailable.get());