Skip to content

Commit a09d002

Browse files
authored
[Fix-18041][Worker]Fix Parameter passing feature is unavailable in K8S Task (#18042)
1 parent 4977d1b commit a09d002

File tree

1 file changed

+1
-0
lines changed
  • dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s

1 file changed

+1
-0
lines changed

dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/AbstractK8sTask.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,7 @@ public void handle(TaskCallBack taskCallBack) throws TaskException {
5353
setExitStatusCode(response.getExitStatusCode());
5454
setAppIds(response.getAppIds());
5555
dealOutParam(abstractK8sTaskExecutor.getTaskOutputParams());
56+
taskRequest.setVarPool(getParameters().getVarPool());
5657
} catch (Exception e) {
5758
log.error("k8s task submit failed with error");
5859
exitStatusCode = -1;

0 commit comments

Comments
 (0)