From 537af052f07f5087a2a51918413268b3371df18b Mon Sep 17 00:00:00 2001 From: JinyLeeChina <42576980+JinyLeeChina@users.noreply.github.com> Date: Mon, 6 Sep 2021 16:39:17 +0800 Subject: [PATCH] [Feature][JsonSplit-api] fix some bug in joint commissioning (#6108) * refactor method of task save * fix ut * fix ut * update method of processDefinition * fix ut * fix some bug in joint commissioning * reomve connects field from h2 * fix bug in joint commissioning Co-authored-by: JinyLeeChina <297062848@qq.com> --- .../dolphinscheduler/service/process/ProcessService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java index 528eef116c..d83f986601 100644 --- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java +++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java @@ -2309,8 +2309,8 @@ public class ProcessService { v.setMaxRetryTimes(taskDefinitionLog.getFailRetryTimes()); v.setRetryInterval(taskDefinitionLog.getFailRetryInterval()); Map taskParamsMap = v.taskParamsToJsonObj(taskDefinitionLog.getTaskParams()); - v.setConditionResult((String) taskParamsMap.get(Constants.CONDITION_RESULT)); - v.setDependence((String) taskParamsMap.get(Constants.DEPENDENCE)); + v.setConditionResult(JSONUtils.toJsonString(taskParamsMap.get(Constants.CONDITION_RESULT))); + v.setDependence(JSONUtils.toJsonString(taskParamsMap.get(Constants.DEPENDENCE))); taskParamsMap.remove(Constants.CONDITION_RESULT); taskParamsMap.remove(Constants.DEPENDENCE); v.setParams(JSONUtils.toJsonString(taskParamsMap));