This is an automated email from the ASF dual-hosted git repository.
davidzollo 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 1651f9f8c9 [Improve][e2e] Disable HTTP server in engine e2e tests to
fix flaky test (#10940)
1651f9f8c9 is described below
commit 1651f9f8c95fc78e6f70063914507ffb64a7cad1
Author: zhiwei.niu <[email protected]>
AuthorDate: Sun May 24 22:31:31 2026 +0800
[Improve][e2e] Disable HTTP server in engine e2e tests to fix flaky test
(#10940)
---
.../apache/seatunnel/engine/e2e/ClusterFailureNoRestoreIT.java | 1 +
.../org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java | 8 ++++++++
.../seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java | 6 ++++++
.../src/test/java/org/apache/seatunnel/engine/e2e/ClusterIT.java | 2 ++
.../java/org/apache/seatunnel/engine/e2e/SeaTunnelSlotIT.java | 2 ++
.../apache/seatunnel/engine/e2e/SplitClusterFaultToleranceIT.java | 2 ++
.../engine/e2e/resourceIsolation/WorkerTagClusterTest.java | 1 +
7 files changed, 22 insertions(+)
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFailureNoRestoreIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFailureNoRestoreIT.java
index 8f37158421..3e46dbf675 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFailureNoRestoreIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFailureNoRestoreIT.java
@@ -79,6 +79,7 @@ public class ClusterFailureNoRestoreIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
index cdd68af2e3..54ccf17d4d 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
@@ -83,6 +83,7 @@ public class ClusterFaultToleranceIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -211,6 +212,7 @@ public class ClusterFaultToleranceIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -305,6 +307,7 @@ public class ClusterFaultToleranceIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -404,6 +407,7 @@ public class ClusterFaultToleranceIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -521,6 +525,7 @@ public class ClusterFaultToleranceIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -621,6 +626,7 @@ public class ClusterFaultToleranceIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -786,6 +792,7 @@ public class ClusterFaultToleranceIT {
hazelcastConfig.setClusterName(TestUtils.getClusterName(testClusterName));
SeaTunnelConfig seaTunnelConfig =
ConfigProvider.locateAndGetSeaTunnelConfig();
seaTunnelConfig.setHazelcastConfig(hazelcastConfig);
+
seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
node2 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -1002,6 +1009,7 @@ public class ClusterFaultToleranceIT {
hazelcastConfig.setClusterName(TestUtils.getClusterName(testClusterName));
SeaTunnelConfig seaTunnelConfig =
ConfigProvider.locateAndGetSeaTunnelConfig();
seaTunnelConfig.setHazelcastConfig(hazelcastConfig);
+
seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
node2 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
index 92af408da3..b16f716730 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
@@ -85,6 +85,7 @@ public class ClusterFaultToleranceTwoPipelineIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -222,6 +223,7 @@ public class ClusterFaultToleranceTwoPipelineIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -327,6 +329,7 @@ public class ClusterFaultToleranceTwoPipelineIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -439,6 +442,7 @@ public class ClusterFaultToleranceTwoPipelineIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -563,6 +567,7 @@ public class ClusterFaultToleranceTwoPipelineIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -673,6 +678,7 @@ public class ClusterFaultToleranceTwoPipelineIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterIT.java
index 778c11cb5d..356c52ca9b 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterIT.java
@@ -55,6 +55,7 @@ public class ClusterIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
@@ -109,6 +110,7 @@ public class ClusterIT {
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
seaTunnelConfig.getEngineConfig().setClassloaderCacheMode(true);
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
try {
node1 =
SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SeaTunnelSlotIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SeaTunnelSlotIT.java
index 98ba753731..eddfeab858 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SeaTunnelSlotIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SeaTunnelSlotIT.java
@@ -48,6 +48,7 @@ public class SeaTunnelSlotIT {
String testClusterName = "testSlotNotEnough";
SeaTunnelConfig seaTunnelConfig =
ConfigProvider.locateAndGetSeaTunnelConfig();
seaTunnelConfig.getHazelcastConfig().setClusterName(testClusterName);
+
seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
// slot num is 3
seaTunnelConfig.getEngineConfig().getSlotServiceConfig().setDynamicSlot(false);
seaTunnelConfig.getEngineConfig().getSlotServiceConfig().setSlotNum(3);
@@ -100,6 +101,7 @@ public class SeaTunnelSlotIT {
String testClusterName = "testSlotEnough";
SeaTunnelConfig seaTunnelConfig =
ConfigProvider.locateAndGetSeaTunnelConfig();
seaTunnelConfig.getHazelcastConfig().setClusterName(testClusterName);
+
seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
// slot num is 10
seaTunnelConfig.getEngineConfig().getSlotServiceConfig().setDynamicSlot(false);
seaTunnelConfig.getEngineConfig().getSlotServiceConfig().setSlotNum(10);
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SplitClusterFaultToleranceIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SplitClusterFaultToleranceIT.java
index 45fd357646..a54290f1d3 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SplitClusterFaultToleranceIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SplitClusterFaultToleranceIT.java
@@ -171,6 +171,7 @@ public class SplitClusterFaultToleranceIT {
seaTunnelConfig
.getHazelcastConfig()
.setClusterName(TestUtils.getClusterName(testClusterName));
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
return seaTunnelConfig;
}
@@ -1064,6 +1065,7 @@ public class SplitClusterFaultToleranceIT {
Config hazelcastConfig = Config.loadFromString(yaml);
hazelcastConfig.setClusterName(testClusterName);
seaTunnelConfig.setHazelcastConfig(hazelcastConfig);
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
return seaTunnelConfig;
}
}
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/resourceIsolation/WorkerTagClusterTest.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/resourceIsolation/WorkerTagClusterTest.java
index 63736a90ae..d173cb7a57 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/resourceIsolation/WorkerTagClusterTest.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/resourceIsolation/WorkerTagClusterTest.java
@@ -121,6 +121,7 @@ public class WorkerTagClusterTest {
hazelcastConfig.setClusterName(TestUtils.getClusterName(testClusterName));
SeaTunnelConfig seaTunnelConfig =
ConfigProvider.locateAndGetSeaTunnelConfig();
seaTunnelConfig.setHazelcastConfig(hazelcastConfig);
+ seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
return seaTunnelConfig;
}
