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-12338-78048bb3c81aa734497ce6b4bf10fe742d66b857 in repository https://gitbox.apache.org/repos/asf/seatunnel.git
commit 39d506a65fb0354b5c49a9d0ff38964426ed672c Author: Goutam Adwant <[email protected]> AuthorDate: Sun Oct 4 22:27:18 2026 +0000 [Test][Zeta] Isolate REST config shade fixture discovery (#12338) Signed-off-by: Goutam Adwant <[email protected]> --- .../rest/RestApiSubmitJobConfigShadeDecryptTest.java | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/RestApiSubmitJobConfigShadeDecryptTest.java b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/RestApiSubmitJobConfigShadeDecryptTest.java index f2d2316b85..1ac746eb0b 100644 --- a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/RestApiSubmitJobConfigShadeDecryptTest.java +++ b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/RestApiSubmitJobConfigShadeDecryptTest.java @@ -110,6 +110,12 @@ public class RestApiSubmitJobConfigShadeDecryptTest { } } + @Test + public void testFixtureStartsWithoutDiscovery() { + Assertions.assertEquals(1, instance.getCluster().getMembers().size()); + Assertions.assertNull(instance.node.getJoiner()); + } + @Test public void testSubmitJobWithHoconFormatDecryptsConfig() throws Exception { String requestUrl = @@ -357,6 +363,7 @@ public class RestApiSubmitJobConfigShadeDecryptTest { } private static String getHazelcastConfig() { + // This single-member fixture must not scan nearby ports used by its REST service. return "hazelcast:\n" + " cluster-name: seatunnel\n" + " network:\n" @@ -366,10 +373,12 @@ public class RestApiSubmitJobConfigShadeDecryptTest { + " CLUSTER_WRITE:\n" + " enabled: true\n" + " join:\n" + + " auto-detection:\n" + + " enabled: false\n" + + " multicast:\n" + + " enabled: false\n" + " tcp-ip:\n" - + " enabled: true\n" - + " member-list:\n" - + " - 127.0.0.1\n" + + " enabled: false\n" + " port:\n" + " auto-increment: true\n" + " port-count: 100\n" @@ -379,7 +388,6 @@ public class RestApiSubmitJobConfigShadeDecryptTest { + "\n" + " properties:\n" + " hazelcast.invocation.max.retry.count: 200\n" - + " hazelcast.tcp.join.port.try.count: 30\n" + " hazelcast.invocation.retry.pause.millis: 2000\n" + " hazelcast.slow.operation.detector.stacktrace.logging.enabled: true\n" + " hazelcast.logging.type: log4j2\n"
