Update TaskExecutionContext with output varPool

apache · Jan 2, 2025 · 96fa389 · 96fa389
1 parent 50923e7
commit 96fa389
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...rc/main/java/org/apache/dolphinscheduler/server/worker/executor/PhysicalTaskExecutor.java b/...rc/main/java/org/apache/dolphinscheduler/server/worker/executor/PhysicalTaskExecutor.java
@@ -84,6 +84,11 @@ public void updateTaskInstanceInfo(final int taskInstanceId) {
                 taskExecutorEventBus.publish(TaskExecutorRuntimeContextChangedLifecycleEvent.of(taskExecutor));
             }
         });
+
+        // Update the `taskExecutionContext` with the JSON-formatted `varPool`
+        // to pass the OUT-typed parameter(s) to the next task node.
+        String varPoolJSONStringUpdated = JSONUtils.toJsonString(physicalTask.getParameters().getVarPool());
+        taskExecutionContext.setVarPool(varPoolJSONStringUpdated);
     }
 
     @Override