[hive] branch master updated: HIVE-22818: Preparation for jetty 9.4.26 upgrade (Laszlo Pinter via Peter Vary)

[pv...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 5819ac5  HIVE-22818: Preparation for jetty 9.4.26 upgrade (Laszlo Pinter via Peter Vary)
5819ac5 is described below

commit 5819ac51568cb0ef020a34530618c27d200efed5
Author: Laszlo Pinter <lp...@cloudera.com>
AuthorDate: Tue Feb 4 10:49:15 2020 +0100

    HIVE-22818: Preparation for jetty 9.4.26 upgrade (Laszlo Pinter via Peter Vary)
---
 .../java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java b/service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java
index 89271d7..c81888a 100644
--- a/service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java
+++ b/service/src/java/org/apache/hive/service/cli/thrift/ThriftHttpCLIService.java
@@ -21,6 +21,7 @@ package org.apache.hive.service.cli.thrift;
 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;
@@ -80,7 +81,8 @@ public class ThriftHttpCLIService extends ThriftCLIService {
       ExecutorService executorService = new ThreadPoolExecutorWithOomHook(minWorkerThreads,
           maxWorkerThreads,workerKeepAliveTime, TimeUnit.SECONDS,
           new SynchronousQueue<Runnable>(), new ThreadFactoryWithGarbageCleanup(threadPoolName), oomHook);
-      ExecutorThreadPool threadPool = new ExecutorThreadPool(executorService);
+
+      ExecutorThreadPool threadPool = new ExecutorThreadPool((ThreadPoolExecutor) executorService);
 
       // HTTP Server
       server = new Server(threadPool);