[incubator-seatunnel] branch dev updated: [Feature][ST-Engine] ST-Engine command line add cancel job (#3685)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia 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 8c2d2c773 [Feature][ST-Engine] ST-Engine command line add cancel job 
(#3685)
8c2d2c773 is described below

commit 8c2d2c7737961f110efa56dc31b7c918487e78d3
Author: ic4y <83933160+i...@users.noreply.github.com>
AuthorDate: Fri Dec 9 10:05:44 2022 +0800

    [Feature][ST-Engine] ST-Engine command line add cancel job (#3685)
---
 .../seatunnel/core/starter/seatunnel/args/ClientCommandArgs.java  | 8 ++++++++
 .../core/starter/seatunnel/command/ClientExecuteCommand.java      | 2 ++
 2 files changed, 10 insertions(+)

diff --git 
a/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/args/ClientCommandArgs.java
 
b/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/args/ClientCommandArgs.java
index 33dd11d4b..920e0162e 100644
--- 
a/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/args/ClientCommandArgs.java
+++ 
b/seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/args/ClientCommandArgs.java
@@ -49,6 +49,10 @@ public class ClientCommandArgs extends AbstractCommandArgs {
         description = "Get job status by JobId")
     private String jobId;
 
+    @Parameter(names = {"-can", "--cancel-job"},
+        description = "Cancel job by JobId")
+    private String cancelJobId;
+
     @Parameter(names = {"-l", "--list"},
         description = "list job status")
     private boolean listJob = false;
@@ -81,6 +85,10 @@ public class ClientCommandArgs extends AbstractCommandArgs {
         return jobId;
     }
 
+    public String getCancelJobId() {
+        return cancelJobId;
+    }
+
     public boolean isListJob(){
         return listJob;
     }
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 05bb824bc..c511b0514 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
@@ -75,6 +75,8 @@ public class ClientExecuteCommand implements 
Command<ClientCommandArgs> {
             } else if (null != clientCommandArgs.getJobId()) {
                 String jobState = 
engineClient.getJobDetailStatus(Long.parseLong(clientCommandArgs.getJobId()));
                 System.out.println(jobState);
+            } else if (null != clientCommandArgs.getCancelJobId()) {
+                
engineClient.cancelJob(Long.parseLong(clientCommandArgs.getCancelJobId()));
             } else {
                 Path configFile = FileUtils.getConfigPath(clientCommandArgs);
                 checkConfigExist(configFile);