diff --git a/service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala b/service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala index 6f62f5cede7..45d63c6b730 100644 --- a/service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala +++ b/service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala @@ -125,6 +125,7 @@ object HttpServer { connector.setPort(port) connector.setReuseAddress(!SystemUtils.IS_OS_WINDOWS) connector.setAcceptQueueSize(math.min(connector.getAcceptors, 8)) + connector.setStopTimeout(stopTimeout) new HttpServer(role, server, connector, collection) }