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());