You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2017/02/01 22:22:32 UTC
hive git commit: HIVE-15783 : small glitch in LlapServiceDriver on
small VMs (Sergey Shelukhin, reviewed by Gopal V)
Repository: hive
Updated Branches:
refs/heads/master d178b195e -> a67eb03c8
HIVE-15783 : small glitch in LlapServiceDriver on small VMs (Sergey Shelukhin, reviewed by Gopal V)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/a67eb03c
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/a67eb03c
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/a67eb03c
Branch: refs/heads/master
Commit: a67eb03c80000c89e5f19d5d1e62c35a63b32f3a
Parents: d178b19
Author: Sergey Shelukhin <se...@apache.org>
Authored: Wed Feb 1 14:22:15 2017 -0800
Committer: Sergey Shelukhin <se...@apache.org>
Committed: Wed Feb 1 14:22:15 2017 -0800
----------------------------------------------------------------------
.../java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/a67eb03c/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
----------------------------------------------------------------------
diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java b/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
index 169be22..eba4401 100644
--- a/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
+++ b/llap-server/src/java/org/apache/hadoop/hive/llap/cli/LlapServiceDriver.java
@@ -196,8 +196,8 @@ public class LlapServiceDriver {
final FileSystem fs = FileSystem.get(conf);
final FileSystem lfs = FileSystem.getLocal(conf).getRawFileSystem();
- final ExecutorService executor =
- Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() / 2,
+ int threadCount = Math.max(1, Runtime.getRuntime().availableProcessors() / 2);
+ final ExecutorService executor = Executors.newFixedThreadPool(threadCount,
new ThreadFactoryBuilder().setNameFormat("llap-pkg-%d").build());
final CompletionService<Void> asyncRunner = new ExecutorCompletionService<Void>(executor);