Skip to content

Commit

Permalink
[Fix][Rest-API] update test case
Browse files Browse the repository at this point in the history
  • Loading branch information
liunaijie committed Oct 25, 2023
1 parent 9a161f0 commit c3dec54
Showing 1 changed file with 2 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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");
Expand Down Expand Up @@ -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(
Expand All @@ -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;
Expand Down

0 comments on commit c3dec54

Please sign in to comment.