(seatunnel) branch dev updated: [Fix][Zeta] Isolate REST test HTTP ports from Hazelcast discovery (#13030)

[github-bot.apache.org via commits]

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

github-merge-queue[bot] pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new d2fc207903 [Fix][Zeta] Isolate REST test HTTP ports from Hazelcast 
discovery (#13030)
d2fc207903 is described below

commit d2fc207903516c23f98f52f073e28c1cd63fe2f0
Author: Daniel <eschedu...@outlook.com>
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 <davidzollo...@gmail.com>
---
 .../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) {