apache/celeborn
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CELEBORN-1317][FOLLOWUP] ServerConnector supports celeborn.master.http.stopTimeout and celeborn.worker.http.stopTimeout

Browse Source 
### 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 <programgeek@163.com>
Signed-off-by: Shuang <lvshuang.xjs@alibaba-inc.com>
This commit is contained in:
SteNicholas 2024-04-01 17:59:12 +08:00 committed by Shuang
parent af5c5060f6
commit df2cb1be9a
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala
View File

@ -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)
}