Fix bug.

WeBankFinTech · Jun 8, 2023 · 82168f2 · 82168f2
1 parent 749edad
commit 82168f2
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/...va/com/webank/wedatasphere/dss/orchestrator/publish/job/CommonUpdateConvertJobStatus.java b/...va/com/webank/wedatasphere/dss/orchestrator/publish/job/CommonUpdateConvertJobStatus.java
@@ -36,8 +36,11 @@ public void toSuccessStatus(OrchestratorPublishJob orchestratorPublishJob) {
 
     public void toFailedStatus(OrchestratorPublishJob orchestratorPublishJob, String errorMsg) {
         orchestratorPublishJob.setStatus(JobStatus.Failed.getStatus());
-        orchestratorPublishJob.setErrorMsg(errorMsg);
+        if (errorMsg.length() > 2048) {
+            orchestratorPublishJob.setErrorMsg(errorMsg.substring(0, 2048));
+        } else {
+            orchestratorPublishJob.setErrorMsg(errorMsg);
+        }
         updateConvertJobStatus(orchestratorPublishJob);
     }
-
 }
diff --git a/...n/java/com/webank/wedatasphere/dss/orchestrator/common/entity/OrchestratorPublishJob.java b/...n/java/com/webank/wedatasphere/dss/orchestrator/common/entity/OrchestratorPublishJob.java
@@ -41,18 +41,16 @@ public String getJobId() {
         return jobId;
     }
 
-    public OrchestratorPublishJob setJobId(String jobId) {
+    public void setJobId(String jobId) {
         this.jobId = jobId;
-		return this;
     }
 
     public String getConversionJobJson() {
         return conversionJobJson;
     }
 
-    public OrchestratorPublishJob setConversionJobJson(String conversionJobJson) {
+    public void setConversionJobJson(String conversionJobJson) {
         this.conversionJobJson = conversionJobJson;
-		return this;
     }
 
     public Date getCreateTime() {