diff --git a/ql/src/java/org/apache/hadoop/hive/ql/processors/LlapCacheResourceProcessor.java b/ql/src/java/org/apache/hadoop/hive/ql/processors/LlapCacheResourceProcessor.java index b11014cb7c..1cfa6ddc75 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/processors/LlapCacheResourceProcessor.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/processors/LlapCacheResourceProcessor.java @@ -133,7 +133,7 @@ private Schema getSchema() { } private void llapCachePurge(final SessionState ss, final LlapRegistryService llapRegistryService) throws Exception { - ExecutorService executorService = Executors.newCachedThreadPool(); + ExecutorService executorService = Executors.newFixedThreadPool(10); List> futures = new ArrayList<>(); Collection instances = llapRegistryService.getInstances().getAll(); for (LlapServiceInstance instance : instances) {