(celeborn) branch main updated: [CELEBORN-1317][FOLLOWUP] ServerConnector supports celeborn.master.http.stopTimeout and celeborn.worker.http.stopTimeout

[re...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rexxiong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/celeborn.git


The following commit(s) were added to refs/heads/main by this push:
     new df2cb1be9 [CELEBORN-1317][FOLLOWUP] ServerConnector supports celeborn.master.http.stopTimeout and celeborn.worker.http.stopTimeout
df2cb1be9 is described below

commit df2cb1be9acc0de837f073aab2f90a247e4b2bf1
Author: SteNicholas <pr...@163.com>
AuthorDate: Mon Apr 1 17:59:12 2024 +0800

    [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 <pr...@163.com>
    Signed-off-by: Shuang <lv...@alibaba-inc.com>
---
 .../main/scala/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)
   }