diff --git llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestFirstInFirstOutComparator.java llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestFirstInFirstOutComparator.java index 53c19b4..9422107 100644 --- llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestFirstInFirstOutComparator.java +++ llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestFirstInFirstOutComparator.java @@ -89,7 +89,7 @@ private SubmitWorkRequestProto createRequest(int fragmentNumber, int numSelfAndU .build(); } - @Test + @Test (timeout = 60000) public void testWaitQueueComparator() throws InterruptedException { TaskWrapper r1 = createTaskWrapper(createRequest(1, 2, 5, 100), false, 100000); TaskWrapper r2 = createTaskWrapper(createRequest(2, 4, 4, 200), false, 100000); @@ -246,7 +246,7 @@ public void testWaitQueueComparator() throws InterruptedException { assertEquals(r2, queue.take()); } - @Test(timeout = 5000) + @Test(timeout = 60000) public void testWaitQueueComparatorWithinDagPriority() throws InterruptedException { TaskWrapper r1 = createTaskWrapper(createRequest(1, 1, 0, 100, 100, 10), false, 100000); TaskWrapper r2 = createTaskWrapper(createRequest(2, 1, 0, 100, 100, 1), false, 100000); @@ -264,7 +264,7 @@ public void testWaitQueueComparatorWithinDagPriority() throws InterruptedExcepti assertEquals(r1, queue.take()); } - @Test(timeout = 5000) + @Test(timeout = 60000) public void testWaitQueueComparatorParallelism() throws InterruptedException { TaskWrapper r1 = createTaskWrapper(createRequest(1, 10, 3, 100, 100, 1), false, 100000); TaskWrapper r2 = createTaskWrapper(createRequest(2, 10, 7, 100, 100, 1), false, 100000); diff --git llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestShortestJobFirstComparator.java llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestShortestJobFirstComparator.java index 9dafd15..fa27be2 100644 --- llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestShortestJobFirstComparator.java +++ llap-server/src/test/org/apache/hadoop/hive/llap/daemon/impl/comparator/TestShortestJobFirstComparator.java @@ -26,7 +26,7 @@ public class TestShortestJobFirstComparator { - @Test(timeout = 5000) + @Test(timeout = 60000) public void testWaitQueueComparator() throws InterruptedException { TaskWrapper r1 = createTaskWrapper(createSubmitWorkRequestProto(1, 2, 100), false, 100000); TaskWrapper r2 = createTaskWrapper(createSubmitWorkRequestProto(2, 4, 200), false, 100000); @@ -161,7 +161,7 @@ public void testWaitQueueComparator() throws InterruptedException { assertEquals(r5, queue.take()); } - @Test(timeout = 5000) + @Test(timeout = 60000) public void testWaitQueueComparatorWithinDagPriority() throws InterruptedException { TaskWrapper r1 = createTaskWrapper(createSubmitWorkRequestProto(1, 1, 0, 100, 10), false, 100000); TaskWrapper r2 = createTaskWrapper(createSubmitWorkRequestProto(2, 1, 0, 100, 1), false, 100000); @@ -179,7 +179,7 @@ public void testWaitQueueComparatorWithinDagPriority() throws InterruptedExcepti assertEquals(r1, queue.take()); } - @Test(timeout = 5000) + @Test(timeout = 60000) public void testWaitQueueComparatorParallelism() throws InterruptedException { TaskWrapper r1 = createTaskWrapper(createSubmitWorkRequestProto(1, 10, 3, 100, 1), false, 100000); // 7 pending TaskWrapper r2 = createTaskWrapper(createSubmitWorkRequestProto(2, 10, 7, 100, 1), false, 100000); // 3 pending