[dolphinscheduler] branch dev updated: fix bug-6208 json parse error in sub process (#6211)

[kirs]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new 8694b9c  fix bug-6208 json parse error in sub process (#6211)
8694b9c is described below

commit 8694b9c8f989eb5c6b0792e5901cba2a207cdcf0
Author: OS <29528966+len...@users.noreply.github.com>
AuthorDate: Wed Sep 15 10:29:26 2021 +0800

    fix bug-6208 json parse error in sub process (#6211)
---
 .../java/org/apache/dolphinscheduler/common/Constants.java  |  1 +
 .../org/apache/dolphinscheduler/common/model/TaskNode.java  | 13 +++++++++++++
 2 files changed, 14 insertions(+)

diff --git 
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java
 
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java
index dc11051..4f9aca5 100644
--- 
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java
+++ 
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java
@@ -755,6 +755,7 @@ public final class Constants {
     public static final String PARENT_WORKFLOW_INSTANCE = 
"parentWorkflowInstance";
     public static final String CONDITION_RESULT = "conditionResult";
     public static final String SWITCH_RESULT = "switchResult";
+    public static final String WAIT_START_TIMEOUT = "waitStartTimeout";
     public static final String DEPENDENCE = "dependence";
     public static final String TASK_TYPE = "taskType";
     public static final String TASK_LIST = "taskList";
diff --git 
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/model/TaskNode.java
 
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/model/TaskNode.java
index d43e1f9..e971263 100644
--- 
a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/model/TaskNode.java
+++ 
b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/model/TaskNode.java
@@ -134,6 +134,10 @@ public class TaskNode {
     @JsonSerialize(using = JSONUtils.JsonDataSerializer.class)
     private String switchResult;
 
+    @JsonDeserialize(using = JSONUtils.JsonDataDeserializer.class)
+    @JsonSerialize(using = JSONUtils.JsonDataSerializer.class)
+    private String waitStartTimeout;
+
     /**
      * task instance priority
      */
@@ -396,6 +400,7 @@ public class TaskNode {
         taskParams.put(Constants.CONDITION_RESULT, this.conditionResult);
         taskParams.put(Constants.DEPENDENCE, this.dependence);
         taskParams.put(Constants.SWITCH_RESULT, this.switchResult);
+        taskParams.put(Constants.WAIT_START_TIMEOUT, this.waitStartTimeout);
         return JSONUtils.toJsonString(taskParams);
     }
 
@@ -450,4 +455,12 @@ public class TaskNode {
     public void setSwitchResult(String switchResult) {
         this.switchResult = switchResult;
     }
+
+    public String getWaitStartTimeout() {
+        return this.waitStartTimeout;
+    }
+
+    public void setWaitStartTimeout(String waitStartTimeout) {
+        this.waitStartTimeout = waitStartTimeout;
+    }
 }