diff --git itests/util/src/main/java/org/apache/hive/beeline/Parallelized.java itests/util/src/main/java/org/apache/hive/beeline/Parallelized.java index a819e26..5cef4c7 100644 --- itests/util/src/main/java/org/apache/hive/beeline/Parallelized.java +++ itests/util/src/main/java/org/apache/hive/beeline/Parallelized.java @@ -30,6 +30,7 @@ */ public class Parallelized extends Parameterized { private static class ThreadPoolScheduler implements RunnerScheduler { + private static final String DEFAULT_TIMEOUT = "10"; private ExecutorService executor; public ThreadPoolScheduler() { @@ -45,7 +46,9 @@ public ThreadPoolScheduler() { public void finished() { executor.shutdown(); try { - executor.awaitTermination(10, TimeUnit.MINUTES); + String timeoutProp = System.getProperty("junit.parallel.timeout", DEFAULT_TIMEOUT); + long timeout = Long.parseLong(timeoutProp); + executor.awaitTermination(timeout, TimeUnit.MINUTES); } catch (InterruptedException exc) { throw new RuntimeException(exc); }