diff --git ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestCustomPartitionVertex.java ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestCustomPartitionVertex.java index 183073afa6b..2be7fbce4d3 100644 --- ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestCustomPartitionVertex.java +++ ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestCustomPartitionVertex.java @@ -33,7 +33,7 @@ import static org.mockito.Mockito.when; public class TestCustomPartitionVertex { - @Test(timeout = 5000) + @Test(timeout = 20000) public void testGetBytePayload() throws IOException { int numBuckets = 10; VertexManagerPluginContext context = mock(VertexManagerPluginContext.class); diff --git ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestDynamicPartitionPruner.java ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestDynamicPartitionPruner.java index 080ee1162bd..d38691e4dbb 100644 --- ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestDynamicPartitionPruner.java +++ ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestDynamicPartitionPruner.java @@ -40,7 +40,7 @@ public class TestDynamicPartitionPruner { - @Test(timeout = 5000) + @Test(timeout = 20000) public void testNoPruning() throws InterruptedException, IOException, HiveException, SerDeException { InputInitializerContext mockInitContext = mock(InputInitializerContext.class); @@ -61,7 +61,7 @@ public void testNoPruning() throws InterruptedException, IOException, HiveExcept } } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testSingleSourceOrdering1() throws InterruptedException, IOException, HiveException, SerDeException { InputInitializerContext mockInitContext = mock(InputInitializerContext.class); @@ -93,7 +93,7 @@ public void testSingleSourceOrdering1() throws InterruptedException, IOException } } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testSingleSourceOrdering2() throws InterruptedException, IOException, HiveException, SerDeException { InputInitializerContext mockInitContext = mock(InputInitializerContext.class); @@ -125,7 +125,7 @@ public void testSingleSourceOrdering2() throws InterruptedException, IOException } } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testSingleSourceMultipleFiltersOrdering1() throws InterruptedException, SerDeException { InputInitializerContext mockInitContext = mock(InputInitializerContext.class); doReturn(2).when(mockInitContext).getVertexNumTasks("v1"); @@ -158,7 +158,7 @@ public void testSingleSourceMultipleFiltersOrdering1() throws InterruptedExcepti } } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testSingleSourceMultipleFiltersOrdering2() throws InterruptedException, SerDeException { InputInitializerContext mockInitContext = mock(InputInitializerContext.class); doReturn(2).when(mockInitContext).getVertexNumTasks("v1"); @@ -191,7 +191,7 @@ public void testSingleSourceMultipleFiltersOrdering2() throws InterruptedExcepti } } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testMultipleSourcesOrdering1() throws InterruptedException, SerDeException { InputInitializerContext mockInitContext = mock(InputInitializerContext.class); doReturn(2).when(mockInitContext).getVertexNumTasks("v1"); @@ -235,7 +235,7 @@ public void testMultipleSourcesOrdering1() throws InterruptedException, SerDeExc } } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testMultipleSourcesOrdering2() throws InterruptedException, SerDeException { InputInitializerContext mockInitContext = mock(InputInitializerContext.class); doReturn(2).when(mockInitContext).getVertexNumTasks("v1"); @@ -279,7 +279,7 @@ public void testMultipleSourcesOrdering2() throws InterruptedException, SerDeExc } } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testMultipleSourcesOrdering3() throws InterruptedException, SerDeException { InputInitializerContext mockInitContext = mock(InputInitializerContext.class); doReturn(2).when(mockInitContext).getVertexNumTasks("v1"); @@ -322,7 +322,7 @@ public void testMultipleSourcesOrdering3() throws InterruptedException, SerDeExc } } - @Test(timeout = 5000, expected = IllegalStateException.class) + @Test(timeout = 20000, expected = IllegalStateException.class) public void testExtraEvents() throws InterruptedException, IOException, HiveException, SerDeException { InputInitializerContext mockInitContext = mock(InputInitializerContext.class);