(seatunnel) branch dev updated: 1 (#7154)

[wanghailin]

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

wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new aeb42bad62 1 (#7154)
aeb42bad62 is described below

commit aeb42bad626db7db9f41542dde4d6c15c58b5773
Author: Guangdong Liu <804167...@qq.com>
AuthorDate: Thu Jul 11 16:24:10 2024 +0800

    1 (#7154)
---
 .../org/apache/seatunnel/engine/e2e/ClusterSeaTunnelContainer.java    | 2 +-
 .../seatunnel/engine/server/rest/RestHttpPostCommandProcessor.java    | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterSeaTunnelContainer.java
 
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterSeaTunnelContainer.java
index 2967d4227f..bf16cab75d 100644
--- 
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterSeaTunnelContainer.java
+++ 
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterSeaTunnelContainer.java
@@ -66,7 +66,7 @@ public class ClusterSeaTunnelContainer extends 
SeaTunnelContainer {
     private static final Path hadoopJar =
             Paths.get(SEATUNNEL_HOME, "lib/seatunnel-hadoop3-3.1.4-uber.jar");
 
-    private static final long CUSTOM_JOB_ID = 123456789;
+    private static final long CUSTOM_JOB_ID = 862969647010611201L;
 
     @Override
     @BeforeEach
diff --git 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpPostCommandProcessor.java
 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpPostCommandProcessor.java
index e250fdf936..7ffe23e46e 100644
--- 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpPostCommandProcessor.java
+++ 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpPostCommandProcessor.java
@@ -131,7 +131,7 @@ public class RestHttpPostCommandProcessor extends 
HttpCommandProcessor<HttpPostC
                         startWithSavePoint,
                         finalJobId);
         JobImmutableInformation jobImmutableInformation = 
restJobExecutionEnvironment.build();
-        Long jobId = jobImmutableInformation.getJobId();
+        long jobId = jobImmutableInformation.getJobId();
         if (!seaTunnelServer.isMasterNode()) {
 
             NodeEngineUtil.sendOperationToMasterNode(
@@ -147,7 +147,7 @@ public class RestHttpPostCommandProcessor extends 
HttpCommandProcessor<HttpPostC
         this.prepareResponse(
                 httpPostCommand,
                 new JsonObject()
-                        .add(RestConstant.JOB_ID, jobId)
+                        .add(RestConstant.JOB_ID, String.valueOf(jobId))
                         .add(RestConstant.JOB_NAME, jobConfig.getName()));
     }