Fix the issue of failing to retrieve logs for K8S tasks.

apache · Nov 12, 2024 · ea85eaf · ea85eaf
1 parent 5e2abd7
commit ea85eaf
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...scheduler-task-k8s/src/main/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sTask.java b/...scheduler-task-k8s/src/main/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sTask.java
@@ -79,6 +79,7 @@ public void init() {
         k8sTaskParameters.setNamespace(k8sConnectionParam.getNamespace());
         k8sTaskParameters.setKubeConfig(kubeConfig);
         k8sTaskExecutionContext.setConfigYaml(kubeConfig);
+        k8sTaskExecutionContext.setNamespace(k8sConnectionParam.getNamespace());
         taskRequest.setK8sTaskExecutionContext(k8sTaskExecutionContext);
         log.info("Initialize k8s task params:{}", JSONUtils.toPrettyJsonString(k8sTaskParameters));
     }