[SPARK-30512] Added a dedicated boss event loop group (apache#639)

Backport of https://issues.apache.org/jira/browse/SPARK-30512. Intent is to upgrade the shuffle service that we run inside NodeManagers to a version with this change.
rshkv · Feb 4, 2020 · f7784aa · f7784aa
1 parent 1501ead
commit f7784aa
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/common/network-common/src/main/java/org/apache/spark/network/server/TransportServer.java b/common/network-common/src/main/java/org/apache/spark/network/server/TransportServer.java
@@ -100,9 +100,10 @@ public int getPort() {
   private void init(String hostToBind, int portToBind) {
 
     IOMode ioMode = IOMode.valueOf(conf.ioMode());
-    EventLoopGroup bossGroup =
-      NettyUtils.createEventLoop(ioMode, conf.serverThreads(), conf.getModuleName() + "-server");
-    EventLoopGroup workerGroup = bossGroup;
+    EventLoopGroup bossGroup = NettyUtils.createEventLoop(ioMode, 1,
+      conf.getModuleName() + "-boss");
+    EventLoopGroup workerGroup =  NettyUtils.createEventLoop(ioMode, conf.serverThreads(),
+      conf.getModuleName() + "-server");
 
     bootstrap = new ServerBootstrap()
       .group(bossGroup, workerGroup)