Skip to content

Commit 8905f2b

Browse files
committed
[Fix][CI] Upgrade all-connectors-it-3/7 timeout
1 parent 705bd76 commit 8905f2b

File tree

2 files changed

+11
-3
lines changed

2 files changed

+11
-3
lines changed

seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/CoordinatorServiceTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -79,8 +79,7 @@ public void testMasterNodeActive() {
7979
CoordinatorService coordinatorService1 = server1.getCoordinatorService();
8080
Assertions.assertTrue(coordinatorService1.isCoordinatorActive());
8181

82-
Assertions.assertThrows(
83-
SeaTunnelEngineException.class, () -> server2.getCoordinatorService());
82+
Assertions.assertThrows(SeaTunnelEngineException.class, server2::getCoordinatorService);
8483

8584
// shutdown instance1
8685
instance1.shutdown();

seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/rest/RestApiHttpsTest.java

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
import org.apache.seatunnel.engine.server.SeaTunnelServerStarter;
2626
import org.apache.seatunnel.engine.server.TestUtils;
2727

28+
import org.junit.jupiter.api.AfterAll;
2829
import org.junit.jupiter.api.Assertions;
2930
import org.junit.jupiter.api.BeforeAll;
3031
import org.junit.jupiter.api.Test;
@@ -50,12 +51,14 @@ public class RestApiHttpsTest extends AbstractSeaTunnelServerTest {
5051
private static final String SERVER_KEYSTORE_PASSWORD = "server_keystore_password";
5152
private static final String CLIENT_KEYSTORE_PASSWORD = "client_keystore_password";
5253

54+
private static SeaTunnelConfig seaTunnelConfig;
55+
5356
@BeforeAll
5457
public void setUp() {
5558
String name = this.getClass().getName();
5659
Config hazelcastConfig = Config.loadFromString(getHazelcastConfig());
5760
hazelcastConfig.setClusterName(TestUtils.getClusterName("RestApiHttpsTest_" + name));
58-
SeaTunnelConfig seaTunnelConfig = loadSeaTunnelConfig();
61+
seaTunnelConfig = loadSeaTunnelConfig();
5962
seaTunnelConfig.setHazelcastConfig(hazelcastConfig);
6063
seaTunnelConfig.getEngineConfig().setMode(ExecutionMode.LOCAL);
6164

@@ -75,6 +78,12 @@ public void setUp() {
7578
LOGGER = nodeEngine.getLogger(AbstractSeaTunnelServerTest.class);
7679
}
7780

81+
@AfterAll
82+
public void resetConfig() {
83+
seaTunnelConfig.getEngineConfig().getHttpConfig().setEnabled(false);
84+
seaTunnelConfig.getEngineConfig().getHttpConfig().setEnableHttps(false);
85+
}
86+
7887
public String getPath(String confFile) {
7988
return System.getProperty("user.dir") + "/src/test/resources/https/" + confFile;
8089
}

0 commit comments

Comments
 (0)