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 9ecca87ca9..5d05d8ab63 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
@@ -36,7 +36,7 @@ public class VarPoolUtils {
         Map<String,Object> taskParams = JSONUtils.parseObject(taskParamsJson, HashMap.class);
 
         Object localParamsObject = taskParams.get("localParams");
-        if (null != localParamsObject && propToValue.size() >0) {
+        if (null != localParamsObject && null != propToValue && propToValue.size() > 0) {
             ArrayList<Object> localParams = (ArrayList)localParamsObject;
             for (int i = 0; i < localParams.size(); i++) {
                 Map<String,String> map = (Map)localParams.get(i);