From 7dd717af16f374c217f956b7c55d19161580dbd3 Mon Sep 17 00:00:00 2001 From: BoYiZhang Date: Wed, 21 Oct 2020 23:32:22 +0800 Subject: [PATCH] When running a task, the resource file is lost, which results in an error --- .../common/utils/VarPoolUtils.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/VarPoolUtils.java b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/VarPoolUtils.java index 5d05d8ab63..89a8605a99 100644 --- a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/VarPoolUtils.java +++ b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/VarPoolUtils.java @@ -26,6 +26,12 @@ import java.util.Map; public class VarPoolUtils { + private static final String LOCALPARAMS = "localParams"; + + private static final String PROP = "prop"; + + private static final String VALUE = "value"; + /** * setTaskNodeLocalParams * @param taskNode taskNode @@ -35,17 +41,17 @@ public class VarPoolUtils { String taskParamsJson = taskNode.getParams(); Map taskParams = JSONUtils.parseObject(taskParamsJson, HashMap.class); - Object localParamsObject = taskParams.get("localParams"); + Object localParamsObject = taskParams.get(LOCALPARAMS); if (null != localParamsObject && null != propToValue && propToValue.size() > 0) { ArrayList localParams = (ArrayList)localParamsObject; for (int i = 0; i < localParams.size(); i++) { Map map = (Map)localParams.get(i); - String prop = map.get("prop"); + String prop = map.get(PROP); if (StringUtils.isNotEmpty(prop) && propToValue.containsKey(prop)) { - map.put("value",(String)propToValue.get(prop)); + map.put(VALUE,(String)propToValue.get(prop)); } } - taskParams.put("localParams",localParams); + taskParams.put(LOCALPARAMS,localParams); } taskNode.setParams(JSONUtils.toJsonString(taskParams)); }