This is an automated email from the ASF dual-hosted git repository.

abstractdog pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tez.git


The following commit(s) were added to refs/heads/master by this push:
     new 051e90f03 TEZ-4394: Netty4 ShuffleHandler: should use 1 boss thread 
(#256) (Laszlo Bodor reviewed by Rajesh Balamohan)
051e90f03 is described below

commit 051e90f033bb4fb0d7b78ef625d4a3353b727b8c
Author: Bodor Laszlo <[email protected]>
AuthorDate: Tue Feb 28 09:35:34 2023 +0100

    TEZ-4394: Netty4 ShuffleHandler: should use 1 boss thread (#256) (Laszlo 
Bodor reviewed by Rajesh Balamohan)
---
 .../src/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 3262c7c34..c6657750f 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 @@ public class ShuffleHandler extends AuxiliaryService {
 
     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());

Reply via email to