Hisoka-X commented on code in PR #7903:
URL: https://github.com/apache/seatunnel/pull/7903#discussion_r1816515456
##########
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/JettyService.java:
##########
@@ -70,14 +73,22 @@
/** The Jetty service for SeaTunnel engine server. */
@Slf4j
public class JettyService {
+
private NodeEngineImpl nodeEngine;
private SeaTunnelConfig seaTunnelConfig;
Server server;
public JettyService(NodeEngineImpl nodeEngine, SeaTunnelConfig
seaTunnelConfig) {
this.nodeEngine = nodeEngine;
this.seaTunnelConfig = seaTunnelConfig;
- this.server = new
Server(seaTunnelConfig.getEngineConfig().getHttpConfig().getPort());
+ int port = seaTunnelConfig.getEngineConfig().getHttpConfig().getPort();
+ if
(seaTunnelConfig.getEngineConfig().getHttpConfig().isEnableDynamicPort()) {
+ port =
+ chooseAppropriatePort(
+ port,
seaTunnelConfig.getEngineConfig().getHttpConfig().getPortRange());
+ }
+ log.info("Jetty will start on port: {}", port);
Review Comment:
```suggestion
log.info("SeaTunnel REST service will start on port {}", port);
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
