Fix out parameter may loss

apache · Feb 22, 2024 · 8651d39 · 8651d39
1 parent 5213290
commit 8651d39
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/.../main/java/org/apache/dolphinscheduler/plugin/task/api/parameters/AbstractParameters.java b/.../main/java/org/apache/dolphinscheduler/plugin/task/api/parameters/AbstractParameters.java
@@ -36,11 +36,11 @@
 import java.util.Map;
 import java.util.Objects;
 
-import lombok.extern.slf4j.Slf4j;
-
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.node.ArrayNode;
 
+import lombok.extern.slf4j.Slf4j;
+
 @Slf4j
 public abstract class AbstractParameters implements IParameters {
 
@@ -161,8 +161,11 @@ public void dealOutParam(Map<String, String> taskOutputParams) {
             if (StringUtils.isNotEmpty(propValue)) {
                 info.setValue(propValue);
                 addPropertyToValPool(info);
-            } else {
-                log.warn("Cannot find the output parameter {} in the task output parameters", info.getProp());
+                continue;
+            }
+            addPropertyToValPool(info);
+            if (StringUtils.isEmpty(info.getValue())) {
+                log.warn("The output parameter {} value is empty and cannot find the out parameter from task output", info);
             }
         }
     }