From 3dd05f7a48b628ff91532854fd7b0146c7de3818 Mon Sep 17 00:00:00 2001 From: Mighten Dai Date: Thu, 26 Dec 2024 17:28:18 +0800 Subject: [PATCH] Update `TaskExecutionContext` with output `varPool` --- .../server/worker/executor/PhysicalTaskExecutor.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/executor/PhysicalTaskExecutor.java b/dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/executor/PhysicalTaskExecutor.java index 3886dad3fe49..9349a55da8ba 100644 --- a/dolphinscheduler-worker/src/main/java/org/apache/dolphinscheduler/server/worker/executor/PhysicalTaskExecutor.java +++ b/dolphinscheduler-worker/src/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