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;