diff --git a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java index 305ca7b3b27e..4cd27c55648b 100644 --- a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java +++ b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java @@ -17,8 +17,6 @@ package org.apache.seatunnel.engine.e2e; -import org.apache.seatunnel.common.config.Common; -import org.apache.seatunnel.common.config.DeployMode; import org.apache.seatunnel.engine.client.SeaTunnelClient; import org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment; import org.apache.seatunnel.engine.client.job.ClientJobProxy; @@ -63,7 +61,6 @@ void beforeClass() throws Exception { SeaTunnelConfig seaTunnelConfig = ConfigProvider.locateAndGetSeaTunnelConfig(); seaTunnelConfig.getHazelcastConfig().setClusterName(testClusterName); hazelcastInstance = SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig); - Common.setDeployMode(DeployMode.CLIENT); String filePath = TestUtils.getResource("stream_fakesource_to_file.conf"); JobConfig jobConfig = new JobConfig(); jobConfig.setName("fake_to_file"); @@ -278,9 +275,7 @@ private Response submitJob(String jobMode) { + " }\n" + " ]\n" + "}"; - String parameters = "jobId=1&jobName=test&isStartWithSavePoint=false"; - // Only jobName is compared because jobId is randomly generated if isStartWithSavePoint is - // false + Response response = given().body(requestBody) .post( @@ -290,9 +285,7 @@ private Response submitJob(String jobMode) { .getLocalMember() .getAddress() .getPort() - + RestConstant.SUBMIT_JOB_URL - + "?" - + parameters); + + RestConstant.SUBMIT_JOB_URL); response.then().statusCode(200).body("jobName", equalTo("test")); return response;