HIVE-17288: LlapOutputFormatService: Increase netty event loop threads (Rajesh Balamohan, reviewed by Jason Dere)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/f3bbc3c8 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/f3bbc3c8 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/f3bbc3c8 Branch: refs/heads/hive-14535 Commit: f3bbc3c851841a47a1de90a90958fadb366527e9 Parents: 76d6e8a Author: Jason Dere <jd...@hortonworks.com> Authored: Fri Sep 29 11:14:04 2017 -0700 Committer: Jason Dere <jd...@hortonworks.com> Committed: Fri Sep 29 11:14:04 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hive/llap/LlapOutputFormatService.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/f3bbc3c8/ql/src/java/org/apache/hadoop/hive/llap/LlapOutputFormatService.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/llap/LlapOutputFormatService.java b/ql/src/java/org/apache/hadoop/hive/llap/LlapOutputFormatService.java index 586006b..30d5eb5 100644 --- a/ql/src/java/org/apache/hadoop/hive/llap/LlapOutputFormatService.java +++ b/ql/src/java/org/apache/hadoop/hive/llap/LlapOutputFormatService.java @@ -106,7 +106,8 @@ public class LlapOutputFormatService { int portFromConf = HiveConf.getIntVar(conf, HiveConf.ConfVars.LLAP_DAEMON_OUTPUT_SERVICE_PORT); int sendBufferSize = HiveConf.getIntVar(conf, HiveConf.ConfVars.LLAP_DAEMON_OUTPUT_SERVICE_SEND_BUFFER_SIZE); - eventLoopGroup = new NioEventLoopGroup(1); + // Netty defaults to no of processors * 2. Can be changed via -Dio.netty.eventLoopThreads + eventLoopGroup = new NioEventLoopGroup(); serverBootstrap = new ServerBootstrap(); serverBootstrap.group(eventLoopGroup); serverBootstrap.channel(NioServerSocketChannel.class);
