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)); }