This is an automated email from the ASF dual-hosted git repository. github-merge-queue[bot] pushed a commit to branch gh-readonly-queue/dev/pr-13030-9544fb8cf21843239bf835ca1ac8f82afe0ddd96 in repository https://gitbox.apache.org/repos/asf/seatunnel.git
commit d2fc207903516c23f98f52f073e28c1cd63fe2f0 Author: Daniel <[email protected]> AuthorDate: Sat Oct 31 12:39:12 2026 +0000 [Fix][Zeta] Isolate REST test HTTP ports from Hazelcast discovery (#13030) Co-authored-by: David Zollo <[email protected]> --- .../apache/seatunnel/engine/server/rest/OptionRulesApiTest.java | 2 +- .../server/rest/RestApiSubmitJobStartWithSavePointTest.java | 8 ++++++-- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/OptionRulesApiTest.java b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/OptionRulesApiTest.java index d5517b3137..168111e965 100644 --- a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/OptionRulesApiTest.java +++ b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/OptionRulesApiTest.java @@ -48,7 +48,7 @@ import static org.hamcrest.Matchers.hasItem; class OptionRulesApiTest { private static final Logger LOG = LogManager.getLogger(OptionRulesApiTest.class); - private static final int HTTP_PORT = 18082; + private static final int HTTP_PORT = TestUtils.getAvailablePort(); private static final int HAZELCAST_PORT = TestUtils.getAvailablePort(100); private static HazelcastInstanceImpl instance; diff --git a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/RestApiSubmitJobStartWithSavePointTest.java b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/RestApiSubmitJobStartWithSavePointTest.java index fae9809a02..ab72a31307 100644 --- a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/RestApiSubmitJobStartWithSavePointTest.java +++ b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/RestApiSubmitJobStartWithSavePointTest.java @@ -76,6 +76,8 @@ public class RestApiSubmitJobStartWithSavePointTest { private static final String SOURCE_FACTORY_ID = "FakeSource"; private static final String TEST_JOB_NAME = "test"; private static final int HAZELCAST_PORT = TestUtils.getAvailablePort(100); + // The two members can share HttpConfig; each needs its own HTTP listener port. + private static final int HTTP_PORT_COUNT = 2; private HazelcastInstanceImpl masterInstance; private HazelcastInstanceImpl workerInstance; @@ -92,7 +94,8 @@ public class RestApiSubmitJobStartWithSavePointTest { checkpointDir = Files.createTempDirectory(clusterName + "_checkpoint_"); SeaTunnelConfig masterConfig = createSeaTunnelConfig(clusterName, 20000, false); - SeaTunnelConfig workerConfig = createSeaTunnelConfig(clusterName, 23000, true); + int workerHttpPort = TestUtils.getAvailablePort(HTTP_PORT_COUNT); + SeaTunnelConfig workerConfig = createSeaTunnelConfig(clusterName, workerHttpPort, true); masterInstance = SeaTunnelServerStarter.createMasterHazelcastInstance(masterConfig); workerInstance = SeaTunnelServerStarter.createWorkerHazelcastInstance(workerConfig); @@ -440,7 +443,8 @@ public class RestApiSubmitJobStartWithSavePointTest { if (enableRest) { httpConfig.setPort(httpPort); httpConfig.setEnableDynamicPort(true); - httpConfig.setPortRange(2000); + // Jetty includes the upper endpoint of the range. + httpConfig.setPortRange(HTTP_PORT_COUNT - 1); } if (checkpointDir != null) {
