From 27f19fd3ea546baaa67c2d9a282a0c6991ea32b7 Mon Sep 17 00:00:00 2001 From: Laszlo Bodor Date: Mon, 7 Mar 2022 14:33:43 +0100 Subject: [PATCH] TEZ-4394: Netty4 ShuffleHandler: should use 1 boss thread --- .../main/java/org/apache/tez/auxservices/ShuffleHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java b/tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java index 3262c7c342..c6657750f4 100644 --- a/tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java +++ b/tez-plugins/tez-aux-services/src/main/java/org/apache/tez/auxservices/ShuffleHandler.java @@ -531,7 +531,7 @@ protected void serviceInit(Configuration conf) throws Exception { final String BOSS_THREAD_NAME_PREFIX = "Tez Shuffle Handler 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());