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 f34b385..90b6e6e 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 @@ -119,6 +119,8 @@ import org.jboss.netty.util.HashedWheelTimer; import org.jboss.netty.util.Timer; +import io.netty.util.NetUtil; + public class ShuffleHandler implements AttemptRegistrationListener { private static final Logger LOG = LoggerFactory.getLogger(ShuffleHandler.class); @@ -327,6 +329,7 @@ public void start() throws Exception { throw new RuntimeException(ex); } bootstrap.setPipelineFactory(pipelineFact); + bootstrap.setOption("backlog", NetUtil.SOMAXCONN); port = conf.getInt(SHUFFLE_PORT_CONFIG_KEY, DEFAULT_SHUFFLE_PORT); Channel ch = bootstrap.bind(new InetSocketAddress(port)); accepted.add(ch); @@ -336,7 +339,8 @@ public void start() throws Exception { if (dirWatcher != null) { dirWatcher.start(); } - LOG.info("LlapShuffleHandler" + " listening on port " + port); + LOG.info("LlapShuffleHandler" + " listening on port " + port + " (SOMAXCONN: " + bootstrap.getOption("backlog") + + ")"); } public static void initializeAndStart(Configuration conf) throws Exception {