diff --git pom.xml pom.xml index 9871bae60e..f0de304e2f 100644 --- pom.xml +++ pom.xml @@ -171,7 +171,7 @@ 5.5.1 3.0.1 1.1 - 9.3.25.v20180904 + 9.4.14.v20181114 1.19 2.22.2 diff --git service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java index 89271d7020..cf66b179fe 100644 --- service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java +++ service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java @@ -21,6 +21,7 @@ import java.util.Arrays; import java.util.concurrent.ExecutorService; import java.util.concurrent.SynchronousQueue; +import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import javax.ws.rs.HttpMethod; @@ -77,7 +78,7 @@ protected void initServer() { // Start with minWorkerThreads, expand till maxWorkerThreads and reject // subsequent requests String threadPoolName = "HiveServer2-HttpHandler-Pool"; - ExecutorService executorService = new ThreadPoolExecutorWithOomHook(minWorkerThreads, + ThreadPoolExecutor executorService = new ThreadPoolExecutorWithOomHook(minWorkerThreads, maxWorkerThreads,workerKeepAliveTime, TimeUnit.SECONDS, new SynchronousQueue(), new ThreadFactoryWithGarbageCleanup(threadPoolName), oomHook); ExecutorThreadPool threadPool = new ExecutorThreadPool(executorService);