This is an automated email from the ASF dual-hosted git repository.

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new a09d002288 [Fix-18041][Worker]Fix Parameter passing feature is 
unavailable in K8S Task (#18042)
a09d002288 is described below

commit a09d002288265ff7084a35956a363b8df14b9fea
Author: njnu-seafish <[email protected]>
AuthorDate: Fri Mar 13 17:32:40 2026 +0800

    [Fix-18041][Worker]Fix Parameter passing feature is unavailable in K8S Task 
(#18042)
---
 .../org/apache/dolphinscheduler/plugin/task/api/k8s/AbstractK8sTask.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/AbstractK8sTask.java
 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/AbstractK8sTask.java
index f77170f482..9646ffa2d3 100644
--- 
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/AbstractK8sTask.java
+++ 
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/AbstractK8sTask.java
@@ -53,6 +53,7 @@ public abstract class AbstractK8sTask extends 
AbstractRemoteTask {
             setExitStatusCode(response.getExitStatusCode());
             setAppIds(response.getAppIds());
             dealOutParam(abstractK8sTaskExecutor.getTaskOutputParams());
+            taskRequest.setVarPool(getParameters().getVarPool());
         } catch (Exception e) {
             log.error("k8s task submit failed with error");
             exitStatusCode = -1;

Reply via email to