[CELEBORN-1317][FOLLOWUP] ServerConnector supports celeborn.master.ht…

…tp.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 <[email protected]> Signed-off-by: Shuang <[email protected]>
apache · Apr 1, 2024 · df2cb1b · df2cb1b
1 parent af5c506
commit df2cb1b
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -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)
   }