[hive] 02/02: HIVE-23247: Increase timeout for some tez tests (Zoltan Haindrich reviewed by Peter Vary)

[kgyrtkirk]

This is an automated email from the ASF dual-hosted git repository.

kgyrtkirk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git

commit cd1ab41b3e17df761a7bda665ac64fba594647a0
Author: Zoltan Haindrich <k...@rxd.hu>
AuthorDate: Tue Apr 21 09:59:14 2020 +0000

    HIVE-23247: Increase timeout for some tez tests (Zoltan Haindrich reviewed 
by Peter Vary)
    
    Signed-off-by: Zoltan Haindrich <zhaindr...@cloudera.com>
---
 .../hive/ql/exec/tez/TestCustomPartitionVertex.java    |  2 +-
 .../hive/ql/exec/tez/TestDynamicPartitionPruner.java   | 18 +++++++++---------
 2 files changed, 10 insertions(+), 10 deletions(-)

diff --git 
a/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestCustomPartitionVertex.java 
b/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestCustomPartitionVertex.java
index 183073a..2be7fbc 100644
--- 
a/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestCustomPartitionVertex.java
+++ 
b/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestCustomPartitionVertex.java
@@ -33,7 +33,7 @@ import static org.mockito.Mockito.mock;
 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 
a/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestDynamicPartitionPruner.java
 
b/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestDynamicPartitionPruner.java
index 080ee11..d38691e 100644
--- 
a/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestDynamicPartitionPruner.java
+++ 
b/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestDynamicPartitionPruner.java
@@ -40,7 +40,7 @@ import org.junit.Test;
 
 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 class TestDynamicPartitionPruner {
     }
   }
 
-  @Test(timeout = 5000)
+  @Test(timeout = 20000)
   public void testSingleSourceOrdering1() throws InterruptedException, 
IOException, HiveException,
       SerDeException {
     InputInitializerContext mockInitContext = 
mock(InputInitializerContext.class);
@@ -93,7 +93,7 @@ public class TestDynamicPartitionPruner {
     }
   }
 
-  @Test(timeout = 5000)
+  @Test(timeout = 20000)
   public void testSingleSourceOrdering2() throws InterruptedException, 
IOException, HiveException,
       SerDeException {
     InputInitializerContext mockInitContext = 
mock(InputInitializerContext.class);
@@ -125,7 +125,7 @@ public class TestDynamicPartitionPruner {
     }
   }
 
-  @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 class TestDynamicPartitionPruner {
     }
   }
 
-  @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 class TestDynamicPartitionPruner {
     }
   }
 
-  @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 class TestDynamicPartitionPruner {
     }
   }
 
-  @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 class TestDynamicPartitionPruner {
     }
   }
 
-  @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 class TestDynamicPartitionPruner {
     }
   }
 
-  @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);