From df2cb1be9acc0de837f073aab2f90a247e4b2bf1 Mon Sep 17 00:00:00 2001 From: SteNicholas Date: Mon, 1 Apr 2024 17:59:12 +0800 Subject: [PATCH] [CELEBORN-1317][FOLLOWUP] ServerConnector supports celeborn.master.http.stopTimeout and celeborn.worker.http.stopTimeout ### What changes were proposed in this pull request? `ServerConnector` supports `celeborn.master.http.stopTimeout` and `celeborn.worker.http.stopTimeout`. ### Why are the changes needed? Jetty `Server` supports `celeborn.master.http.stopTimeout` and `celeborn.worker.http.stopTimeout`, but `ServerConnector` does not support, which default stop timeout is 5min. ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Local test. Closes #2437 from SteNicholas/CELEBORN-1317. Authored-by: SteNicholas Signed-off-by: Shuang --- .../org/apache/celeborn/server/common/http/HttpServer.scala | 1 + 1 file changed, 1 insertion(+) 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 6f62f5ced..45d63c6b7 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) }