From d3e378e98f931b5a0a485c6176ad9b2cf141b32f Mon Sep 17 00:00:00 2001
From: ShengHuang <huangshengtx@163.com>
Date: Mon, 16 Mar 2026 15:48:21 +0800
Subject: [PATCH] [Improvement][Worker] Centralize varPool sync after physical
 task execution

---
 .../server/worker/executor/PhysicalTaskExecutor.java             | 1 +
 1 file changed, 1 insertion(+)

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 7118a099d5f9..ad52904ca014 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
@@ -87,6 +87,7 @@ public void updateTaskInstanceInfo(final int taskInstanceId) {
                 taskExecutorEventBus.publish(TaskExecutorRuntimeContextChangedLifecycleEvent.of(taskExecutor));
             }
         });
+        this.getTaskExecutionContext().setVarPool(this.physicalTask.getParameters().getVarPool());
     }
 
     @Override