diff --git a/llap-server/src/java/org/apache/hadoop/hive/llap/shufflehandler/ShuffleHandler.java b/llap-server/src/java/org/apache/hadoop/hive/llap/shufflehandler/ShuffleHandler.java index 70f568ee90..9893210bd9 100644 --- a/llap-server/src/java/org/apache/hadoop/hive/llap/shufflehandler/ShuffleHandler.java +++ b/llap-server/src/java/org/apache/hadoop/hive/llap/shufflehandler/ShuffleHandler.java @@ -299,7 +299,7 @@ public void operationComplete(ChannelFuture future) throws Exception { final String BOSS_THREAD_NAME_PREFIX = "ShuffleHandler Netty Boss #"; AtomicInteger bossThreadCounter = new AtomicInteger(0); - bossGroup = new NioEventLoopGroup(maxShuffleThreads, new ThreadFactory() { + bossGroup = new NioEventLoopGroup(1, new ThreadFactory() { @Override public Thread newThread(Runnable r) { return new Thread(r, BOSS_THREAD_NAME_PREFIX + bossThreadCounter.incrementAndGet());