This is an automated email from the ASF dual-hosted git repository.
ic4y pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 660a19efd [Improve][ST Engine] improve engine client api name (#3644)
660a19efd is described below
commit 660a19efd7ec7cfc6745b995a8054a63b5aaffad
Author: Eric <[email protected]>
AuthorDate: Mon Dec 5 21:42:24 2022 +0800
[Improve][ST Engine] improve engine client api name (#3644)
* improve engine client api name
---
README.md | 5 +---
docs/en/about.md | 2 +-
docs/en/start-v2/locally/quick-start-flink.md | 2 +-
.../locally/quick-start-seatunnel-engine.md | 2 +-
.../seatunnel/command/ClientExecuteCommand.java | 2 +-
seatunnel-engine/README.md | 2 +-
.../seatunnel/engine/client/SeaTunnelClient.java | 34 +++++++++++++++++++---
.../engine/client/SeaTunnelClientTest.java | 8 ++---
....java => SeaTunnelGetJobDetailStatusCodec.java} | 5 ++--
.../SeaTunnelEngine.yaml | 2 +-
.../engine/server/CoordinatorService.java | 4 +--
.../engine/server/master/JobHistoryService.java | 6 ++--
...ation.java => GetJobDetailStatusOperation.java} | 8 ++---
...bStateTask.java => GetJobDetailStatusTask.java} | 14 ++++-----
.../task/SeaTunnelMessageTaskFactoryProvider.java | 6 ++--
.../ClientToServerOperationDataSerializerHook.java | 4 +--
.../server/master/JobHistoryServiceTest.java | 8 ++---
17 files changed, 68 insertions(+), 46 deletions(-)
diff --git a/README.md b/README.md
index ac88e8ce5..86dbb8176 100644
--- a/README.md
+++ b/README.md
@@ -42,7 +42,7 @@ SeaTunnel focuses on data integration and data
synchronization, and is mainly de
## SeaTunnel work flowchart
-
+
The runtime process of SeaTunnel is shown in the figure above.
@@ -94,9 +94,6 @@ https://seatunnel.apache.org/docs/category/start-v2
**Flink**
https://seatunnel.apache.org/docs/category/start-v2
-Detailed documentation on SeaTunnel
-https://seatunnel.apache.org/docs/intro/about
-
## Application practice cases
- Weibo, Value-added Business Department Data Platform
diff --git a/docs/en/about.md b/docs/en/about.md
index 43468f327..6a530df38 100644
--- a/docs/en/about.md
+++ b/docs/en/about.md
@@ -35,7 +35,7 @@ SeaTunnel focuses on data integration and data
synchronization, and is mainly de
## SeaTunnel work flowchart
-
+
The runtime process of SeaTunnel is shown in the figure above.
diff --git a/docs/en/start-v2/locally/quick-start-flink.md
b/docs/en/start-v2/locally/quick-start-flink.md
index 6ad92f01f..f7f58a8d1 100644
--- a/docs/en/start-v2/locally/quick-start-flink.md
+++ b/docs/en/start-v2/locally/quick-start-flink.md
@@ -50,7 +50,7 @@ sink {
```
-More information about config please check [config concept](../concept/config)
+More information about config please check [config
concept](../../concept/config.md)
## Step 3: Run SeaTunnel Application
diff --git a/docs/en/start-v2/locally/quick-start-seatunnel-engine.md
b/docs/en/start-v2/locally/quick-start-seatunnel-engine.md
index b7ffa1478..d2ce05b37 100644
--- a/docs/en/start-v2/locally/quick-start-seatunnel-engine.md
+++ b/docs/en/start-v2/locally/quick-start-seatunnel-engine.md
@@ -42,7 +42,7 @@ sink {
```
-More information about config please check [config concept](../concept/config)
+More information about config please check [config
concept](../../concept/config.md)
## Step 3: Run SeaTunnel Application
diff --git
a/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java
b/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java
index 3c9c8af8d..05bb824bc 100644
---
a/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java
+++
b/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java
@@ -73,7 +73,7 @@ public class ClientExecuteCommand implements
Command<ClientCommandArgs> {
String jobstatus = engineClient.listJobStatus();
System.out.println(jobstatus);
} else if (null != clientCommandArgs.getJobId()) {
- String jobState =
engineClient.getJobState(Long.parseLong(clientCommandArgs.getJobId()));
+ String jobState =
engineClient.getJobDetailStatus(Long.parseLong(clientCommandArgs.getJobId()));
System.out.println(jobState);
} else {
Path configFile = FileUtils.getConfigPath(clientCommandArgs);
diff --git a/seatunnel-engine/README.md b/seatunnel-engine/README.md
index 74827c5b7..7efe83daf 100644
--- a/seatunnel-engine/README.md
+++ b/seatunnel-engine/README.md
@@ -32,4 +32,4 @@ In the future, SeaTunnel Engine will further optimize its
functions to support f
### Quick Start
-https://seatunnel.apache.org/docs/start-v2/local](https://seatunnel.apache.org/docs/start-v2/locally/deployment/
+[Quick Start](../docs/en/start-v2)
diff --git
a/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/SeaTunnelClient.java
b/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/SeaTunnelClient.java
index 9f8a9420b..421bef7ef 100644
---
a/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/SeaTunnelClient.java
+++
b/seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/SeaTunnelClient.java
@@ -20,8 +20,10 @@ package org.apache.seatunnel.engine.client;
import org.apache.seatunnel.engine.client.job.JobClient;
import org.apache.seatunnel.engine.client.job.JobExecutionEnvironment;
import org.apache.seatunnel.engine.common.config.JobConfig;
+import org.apache.seatunnel.engine.core.job.JobStatus;
+import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelGetJobDetailStatusCodec;
import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelGetJobMetricsCodec;
-import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelGetJobStateCodec;
+import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelGetJobStatusCodec;
import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelListJobStatusCodec;
import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelPrintMessageCodec;
@@ -68,13 +70,24 @@ public class SeaTunnelClient implements
SeaTunnelClientInstance {
}
}
- public String getJobState(Long jobId) {
+ /**
+ * get job status and the tasks status
+ *
+ * @param jobId jobId
+ * @return
+ */
+ public String getJobDetailStatus(Long jobId) {
return hazelcastClient.requestOnMasterAndDecodeResponse(
- SeaTunnelGetJobStateCodec.encodeRequest(jobId),
- SeaTunnelGetJobStateCodec::decodeResponse
+ SeaTunnelGetJobDetailStatusCodec.encodeRequest(jobId),
+ SeaTunnelGetJobDetailStatusCodec::decodeResponse
);
}
+ /**
+ * list all jobId and job status
+ *
+ * @return
+ */
public String listJobStatus() {
return hazelcastClient.requestOnMasterAndDecodeResponse(
SeaTunnelListJobStatusCodec.encodeRequest(),
@@ -82,6 +95,19 @@ public class SeaTunnelClient implements
SeaTunnelClientInstance {
);
}
+ /**
+ * get one job status
+ *
+ * @param jobId jobId
+ * @return
+ */
+ public String getJobStatus(Long jobId) {
+ int jobStatusOrdinal =
hazelcastClient.requestOnMasterAndDecodeResponse(
+ SeaTunnelGetJobStatusCodec.encodeRequest(jobId),
+ SeaTunnelGetJobStatusCodec::decodeResponse);
+ return JobStatus.values()[jobStatusOrdinal].toString();
+ }
+
public String getJobMetrics(Long jobId) {
return hazelcastClient.requestOnMasterAndDecodeResponse(
SeaTunnelGetJobMetricsCodec.encodeRequest(jobId),
diff --git
a/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelClientTest.java
b/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelClientTest.java
index 9be38e537..5dbef1700 100644
---
a/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelClientTest.java
+++
b/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelClientTest.java
@@ -94,7 +94,7 @@ public class SeaTunnelClientTest {
return clientJobProxy.waitForJobComplete();
});
- await().atMost(30000, TimeUnit.MILLISECONDS)
+ await().atMost(180000, TimeUnit.MILLISECONDS)
.untilAsserted(() -> Assertions.assertTrue(
objectCompletableFuture.isDone() &&
JobStatus.FINISHED.equals(objectCompletableFuture.get())));
@@ -121,11 +121,11 @@ public class SeaTunnelClientTest {
await().atMost(30000, TimeUnit.MILLISECONDS)
.untilAsserted(() -> Assertions.assertTrue(
- CLIENT.getJobState(jobId).contains("RUNNING") &&
CLIENT.listJobStatus().contains("RUNNING")));
+ CLIENT.getJobDetailStatus(jobId).contains("RUNNING") &&
CLIENT.listJobStatus().contains("RUNNING")));
await().atMost(30000, TimeUnit.MILLISECONDS)
.untilAsserted(() -> Assertions.assertTrue(
- CLIENT.getJobState(jobId).contains("FINISHED") &&
CLIENT.listJobStatus().contains("FINISHED")));
+ CLIENT.getJobDetailStatus(jobId).contains("FINISHED") &&
CLIENT.listJobStatus().contains("FINISHED")));
} catch (ExecutionException | InterruptedException e) {
throw new RuntimeException(e);
@@ -150,7 +150,7 @@ public class SeaTunnelClientTest {
await().atMost(30000, TimeUnit.MILLISECONDS)
.untilAsserted(() -> Assertions.assertTrue(
- CLIENT.getJobState(jobId).contains("FINISHED") &&
CLIENT.listJobStatus().contains("FINISHED")));
+ CLIENT.getJobDetailStatus(jobId).contains("FINISHED") &&
CLIENT.listJobStatus().contains("FINISHED")));
String jobMetrics = CLIENT.getJobMetrics(jobId);
diff --git
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/protocol/codec/SeaTunnelGetJobStateCodec.java
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/protocol/codec/SeaTunnelGetJobDetailStatusCodec.java
similarity index 96%
rename from
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/protocol/codec/SeaTunnelGetJobStateCodec.java
rename to
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/protocol/codec/SeaTunnelGetJobDetailStatusCodec.java
index 9b225608e..3134db5b5 100644
---
a/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/protocol/codec/SeaTunnelGetJobStateCodec.java
+++
b/seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/protocol/codec/SeaTunnelGetJobDetailStatusCodec.java
@@ -20,7 +20,6 @@ package org.apache.seatunnel.engine.core.protocol.codec;
import com.hazelcast.client.impl.protocol.ClientMessage;
import com.hazelcast.client.impl.protocol.Generated;
import com.hazelcast.client.impl.protocol.codec.builtin.*;
-import com.hazelcast.client.impl.protocol.codec.custom.*;
import static com.hazelcast.client.impl.protocol.ClientMessage.*;
import static
com.hazelcast.client.impl.protocol.codec.builtin.FixedSizeTypesCodec.*;
@@ -35,7 +34,7 @@ import static
com.hazelcast.client.impl.protocol.codec.builtin.FixedSizeTypesCod
/**
*/
@Generated("56079ba8d58afe5c98dfe2b5dc6c301a")
-public final class SeaTunnelGetJobStateCodec {
+public final class SeaTunnelGetJobDetailStatusCodec {
//hex: 0xDE0600
public static final int REQUEST_MESSAGE_TYPE = 14550528;
//hex: 0xDE0601
@@ -44,7 +43,7 @@ public final class SeaTunnelGetJobStateCodec {
private static final int REQUEST_INITIAL_FRAME_SIZE =
REQUEST_JOB_ID_FIELD_OFFSET + LONG_SIZE_IN_BYTES;
private static final int RESPONSE_INITIAL_FRAME_SIZE =
RESPONSE_BACKUP_ACKS_FIELD_OFFSET + BYTE_SIZE_IN_BYTES;
- private SeaTunnelGetJobStateCodec() {
+ private SeaTunnelGetJobDetailStatusCodec() {
}
public static ClientMessage encodeRequest(long jobId) {
diff --git
a/seatunnel-engine/seatunnel-engine-core/src/main/resources/client-protocol-definition/SeaTunnelEngine.yaml
b/seatunnel-engine/seatunnel-engine-core/src/main/resources/client-protocol-definition/SeaTunnelEngine.yaml
index ec40e9c92..6c40cfdd8 100644
---
a/seatunnel-engine/seatunnel-engine-core/src/main/resources/client-protocol-definition/SeaTunnelEngine.yaml
+++
b/seatunnel-engine/seatunnel-engine-core/src/main/resources/client-protocol-definition/SeaTunnelEngine.yaml
@@ -118,7 +118,7 @@ methods:
doc: ''
- id: 6
- name: getJobState
+ name: getJobDetailStatus
since: 2.0
doc: ''
request:
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
index 2128ece81..9ee002279 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
@@ -385,7 +385,7 @@ public class CoordinatorService {
public PassiveCompletableFuture<JobStatus> waitForJobComplete(long jobId) {
JobMaster runningJobMaster = runningJobMasterMap.get(jobId);
if (runningJobMaster == null) {
- JobStatus jobStatus =
jobHistoryService.getJobStatus(jobId).getJobStatus();
+ JobStatus jobStatus =
jobHistoryService.getJobDetailState(jobId).getJobStatus();
CompletableFuture<JobStatus> future = new CompletableFuture<>();
future.complete(jobStatus);
return new PassiveCompletableFuture<>(future);
@@ -411,7 +411,7 @@ public class CoordinatorService {
public JobStatus getJobStatus(long jobId) {
JobMaster runningJobMaster = runningJobMasterMap.get(jobId);
if (runningJobMaster == null) {
- return jobHistoryService.getJobStatus(jobId).getJobStatus();
+ return jobHistoryService.getJobDetailState(jobId).getJobStatus();
}
return runningJobMaster.getJobStatus();
}
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
index fffb3f369..0b4d65856 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
@@ -107,7 +107,7 @@ public class JobHistoryService {
}
// Get detailed status of a single job
- public JobStateData getJobStatus(Long jobId) {
+ public JobStateData getJobDetailState(Long jobId) {
return runningJobMasterMap.containsKey(jobId) ?
toJobStateMapper(runningJobMasterMap.get(jobId)) :
finishedJobStateImap.getOrDefault(jobId, null);
}
@@ -117,8 +117,8 @@ public class JobHistoryService {
}
// Get detailed status of a single job as json
- public String getJobStatusAsString(Long jobId) {
- JobStateData jobStatus = getJobStatus(jobId);
+ public String getJobDetailStateAsString(Long jobId) {
+ JobStateData jobStatus = getJobDetailState(jobId);
if (null != jobStatus) {
try {
return objectMapper.writeValueAsString(jobStatus);
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/GetJobStateOperation.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/GetJobDetailStatusOperation.java
similarity index 90%
rename from
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/GetJobStateOperation.java
rename to
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/GetJobDetailStatusOperation.java
index 2e42e42ab..831b41095 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/GetJobStateOperation.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/GetJobDetailStatusOperation.java
@@ -31,15 +31,15 @@ import java.io.IOException;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
-public class GetJobStateOperation extends Operation implements
IdentifiedDataSerializable, AllowedDuringPassiveState {
+public class GetJobDetailStatusOperation extends Operation implements
IdentifiedDataSerializable, AllowedDuringPassiveState {
private Long jobId;
private String response;
- public GetJobStateOperation() {
+ public GetJobDetailStatusOperation() {
}
- public GetJobStateOperation(Long jobId) {
+ public GetJobDetailStatusOperation(Long jobId) {
this.jobId = jobId;
}
@@ -69,7 +69,7 @@ public class GetJobStateOperation extends Operation
implements IdentifiedDataSer
public void run() {
SeaTunnelServer service = getService();
CompletableFuture<String> future = CompletableFuture.supplyAsync(() ->
{
- return
service.getCoordinatorService().getJobHistoryService().getJobStatusAsString(jobId);
+ return
service.getCoordinatorService().getJobHistoryService().getJobDetailStateAsString(jobId);
});
try {
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/GetJobStateTask.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/GetJobDetailStatusTask.java
similarity index 74%
rename from
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/GetJobStateTask.java
rename to
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/GetJobDetailStatusTask.java
index 7aa3b2130..860e00ed3 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/GetJobStateTask.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/GetJobDetailStatusTask.java
@@ -17,25 +17,25 @@
package org.apache.seatunnel.engine.server.protocol.task;
-import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelGetJobStateCodec;
-import org.apache.seatunnel.engine.server.operation.GetJobStateOperation;
+import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelGetJobDetailStatusCodec;
+import
org.apache.seatunnel.engine.server.operation.GetJobDetailStatusOperation;
import com.hazelcast.client.impl.protocol.ClientMessage;
import com.hazelcast.instance.impl.Node;
import com.hazelcast.internal.nio.Connection;
import com.hazelcast.spi.impl.operationservice.Operation;
-public class GetJobStateTask extends AbstractSeaTunnelMessageTask<Long,
String> {
+public class GetJobDetailStatusTask extends AbstractSeaTunnelMessageTask<Long,
String> {
- protected GetJobStateTask(ClientMessage clientMessage, Node node,
Connection connection) {
+ protected GetJobDetailStatusTask(ClientMessage clientMessage, Node node,
Connection connection) {
super(clientMessage, node, connection,
- SeaTunnelGetJobStateCodec::decodeRequest,
- SeaTunnelGetJobStateCodec::encodeResponse);
+ SeaTunnelGetJobDetailStatusCodec::decodeRequest,
+ SeaTunnelGetJobDetailStatusCodec::encodeResponse);
}
@Override
protected Operation prepareOperation() {
- return new GetJobStateOperation(parameters);
+ return new GetJobDetailStatusOperation(parameters);
}
@Override
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/SeaTunnelMessageTaskFactoryProvider.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/SeaTunnelMessageTaskFactoryProvider.java
index 130fe0f36..b857bca17 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/SeaTunnelMessageTaskFactoryProvider.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/SeaTunnelMessageTaskFactoryProvider.java
@@ -18,8 +18,8 @@
package org.apache.seatunnel.engine.server.protocol.task;
import org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelCancelJobCodec;
+import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelGetJobDetailStatusCodec;
import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelGetJobMetricsCodec;
-import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelGetJobStateCodec;
import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelGetJobStatusCodec;
import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelListJobStatusCodec;
import
org.apache.seatunnel.engine.core.protocol.codec.SeaTunnelPrintMessageCodec;
@@ -58,8 +58,8 @@ public class SeaTunnelMessageTaskFactoryProvider implements
MessageTaskFactoryPr
(clientMessage, connection) -> new CancelJobTask(clientMessage,
node, connection));
factories.put(SeaTunnelGetJobStatusCodec.REQUEST_MESSAGE_TYPE,
(clientMessage, connection) -> new GetJobStatusTask(clientMessage,
node, connection));
- factories.put(SeaTunnelGetJobStateCodec.REQUEST_MESSAGE_TYPE,
- (clientMessage, connection) -> new GetJobStateTask(clientMessage,
node, connection));
+ factories.put(SeaTunnelGetJobDetailStatusCodec.REQUEST_MESSAGE_TYPE,
+ (clientMessage, connection) -> new
GetJobDetailStatusTask(clientMessage, node, connection));
factories.put(SeaTunnelListJobStatusCodec.REQUEST_MESSAGE_TYPE,
(clientMessage, connection) -> new
ListJobStatusTask(clientMessage, node, connection));
factories.put(SeaTunnelGetJobMetricsCodec.REQUEST_MESSAGE_TYPE,
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/ClientToServerOperationDataSerializerHook.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/ClientToServerOperationDataSerializerHook.java
index 5910cbded..90c8e8495 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/ClientToServerOperationDataSerializerHook.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/ClientToServerOperationDataSerializerHook.java
@@ -19,8 +19,8 @@ package org.apache.seatunnel.engine.server.serializable;
import
org.apache.seatunnel.engine.common.serializeable.SeaTunnelFactoryIdConstant;
import org.apache.seatunnel.engine.server.operation.CancelJobOperation;
+import
org.apache.seatunnel.engine.server.operation.GetJobDetailStatusOperation;
import org.apache.seatunnel.engine.server.operation.GetJobMetricsOperation;
-import org.apache.seatunnel.engine.server.operation.GetJobStateOperation;
import org.apache.seatunnel.engine.server.operation.GetJobStatusOperation;
import org.apache.seatunnel.engine.server.operation.PrintMessageOperation;
import org.apache.seatunnel.engine.server.operation.SubmitJobOperation;
@@ -85,7 +85,7 @@ public final class ClientToServerOperationDataSerializerHook
implements DataSeri
case GET_JOB_METRICS_OPERATOR:
return new GetJobMetricsOperation();
case GET_JOB_STATE_OPERATION:
- return new GetJobStateOperation();
+ return new GetJobDetailStatusOperation();
default:
throw new IllegalArgumentException("Unknown type id " +
typeId);
}
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/master/JobHistoryServiceTest.java
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/master/JobHistoryServiceTest.java
index 4e9f56f0f..0da169e9b 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/master/JobHistoryServiceTest.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/master/JobHistoryServiceTest.java
@@ -73,17 +73,17 @@ class JobHistoryServiceTest extends
AbstractSeaTunnelServerTest {
// waiting for JOB_3 status turn to RUNNING
await().atMost(60000, TimeUnit.MILLISECONDS)
.untilAsserted(() -> Assertions.assertTrue(
-
server.getCoordinatorService().getJobHistoryService().getJobStatusAsString(JOB_3).contains("TaskGroupLocation")
+
server.getCoordinatorService().getJobHistoryService().getJobDetailStateAsString(JOB_3).contains("TaskGroupLocation")
&&
-
server.getCoordinatorService().getJobHistoryService().getJobStatusAsString(JOB_3).contains("RUNNING")
+
server.getCoordinatorService().getJobHistoryService().getJobDetailStateAsString(JOB_3).contains("RUNNING")
));
// waiting for job1 status turn to FINISHED
await().atMost(60000, TimeUnit.MILLISECONDS)
.untilAsserted(() -> Assertions.assertTrue(
-
server.getCoordinatorService().getJobHistoryService().getJobStatusAsString(JOB_3).contains("TaskGroupLocation")
+
server.getCoordinatorService().getJobHistoryService().getJobDetailStateAsString(JOB_3).contains("TaskGroupLocation")
&&
-
server.getCoordinatorService().getJobHistoryService().getJobStatusAsString(JOB_3).contains("FINISHED")
+
server.getCoordinatorService().getJobHistoryService().getJobDetailStateAsString(JOB_3).contains("FINISHED")
));
}
