This is an automated email from the ASF dual-hosted git repository.
weiraowang 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 65b6a4b097 [Feature-14421][K8S Task] Configurable image pull policy
(#14426)
65b6a4b097 is described below
commit 65b6a4b097a82980dd7b2be120bef4c4f52cf911
Author: Aaron Wang <[email protected]>
AuthorDate: Wed Jul 5 09:17:47 2023 +0800
[Feature-14421][K8S Task] Configurable image pull policy (#14426)
---
docs/docs/en/guide/task/kubernetes.md | 23 ++++++++--------
docs/docs/zh/guide/task/kubernetes.md | 1 +
.../plugin/task/api/k8s/K8sTaskMainParameters.java | 1 +
.../plugin/task/api/k8s/impl/K8sTaskExecutor.java | 31 ++++++++++++---------
.../task/api/parameters/K8sTaskParameters.java | 5 ++--
.../plugin/task/api/k8s/K8sTaskExecutorTest.java | 2 ++
.../dolphinscheduler/plugin/task/k8s/K8sTask.java | 1 +
.../plugin/task/k8s/K8sParametersTest.java | 3 ++
.../plugin/task/k8s/K8sTaskTest.java | 6 ++--
dolphinscheduler-ui/src/locales/en_US/project.ts | 2 ++
dolphinscheduler-ui/src/locales/zh_CN/project.ts | 2 ++
.../task/components/node/fields/use-k8s.ts | 32 +++++++++++++++++++++-
.../projects/task/components/node/format-data.ts | 1 +
.../views/projects/task/components/node/types.ts | 1 +
14 files changed, 82 insertions(+), 29 deletions(-)
diff --git a/docs/docs/en/guide/task/kubernetes.md
b/docs/docs/en/guide/task/kubernetes.md
index 316a82adf7..332669a60c 100644
--- a/docs/docs/en/guide/task/kubernetes.md
+++ b/docs/docs/en/guide/task/kubernetes.md
@@ -16,17 +16,18 @@ K8S task type used to execute a batch task. In this task,
the worker submits the
- Please refer to [DolphinScheduler Task Parameters Appendix](appendix.md)
`Default Task Parameters` section for default parameters.
-| **Parameter** |
**Description**
|
-|------------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
-| Namespace | The namespace for running k8s task.
|
-| Min CPU | Minimum CPU requirement for running k8s task.
|
-| Min Memory | Minimum memory requirement for running k8s task.
|
-| Image | The registry url for image.
|
-| Command | The container execution command (yaml-style array), for
example: ["printenv"]
|
-| Args | The args of execution command (yaml-style array), for
example: ["HOSTNAME", "KUBERNETES_PORT"]
|
-| Custom label | The customized labels for k8s Job.
|
-| Node selector | The label selectors for running k8s pod. Different value
in value set should be seperated by comma, for example: `value1,value2`. You
can refer to
https://kubernetes.io/docs/reference/kubernetes-api/common-definitions/node-selector-requirement/
for configuration of different operators. |
-| Custom parameter | It is a local user-defined parameter for K8S task, these
params will pass to container as environment variables.
|
+| **Parameter** |
**Description**
|
+|-------------------|------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| Namespace | The namespace for running k8s task.
|
+| Min CPU | Minimum CPU requirement for running k8s task.
|
+| Min Memory | Minimum memory requirement for running k8s task.
|
+| Image | The registry url for image.
|
+| Image Pull Policy | The image pull policy for image.
|
+| Command | The container execution command (yaml-style array), for
example: ["printenv"]
|
+| Args | The args of execution command (yaml-style array), for
example: ["HOSTNAME", "KUBERNETES_PORT"]
|
+| Custom label | The customized labels for k8s Job.
|
+| Node selector | The label selectors for running k8s pod. Different value
in value set should be seperated by comma, for example: `value1,value2`. You
can refer to
https://kubernetes.io/docs/reference/kubernetes-api/common-definitions/node-selector-requirement/
for configuration of different operators. |
+| Custom parameter | It is a local user-defined parameter for K8S task, these
params will pass to container as environment variables.
|
## Task Example
diff --git a/docs/docs/zh/guide/task/kubernetes.md
b/docs/docs/zh/guide/task/kubernetes.md
index 0409f116eb..dbfbcd20d2 100644
--- a/docs/docs/zh/guide/task/kubernetes.md
+++ b/docs/docs/zh/guide/task/kubernetes.md
@@ -22,6 +22,7 @@ kubernetes任务类型，用于在kubernetes上执行一个短时和批处理的
| 最小CPU | 任务在kubernetes上运行所需的最小CPU
|
| 最小内存 | 任务在kubernetes上运行所需的最小内存
|
| 镜像 | 镜像地址
|
+| 镜像拉取策略 | 镜像的拉取策略
|
| 容器执行命令 | 容器执行命令（yaml格式数组），例如：["printenv"]
|
| 执行命令参数 | 执行命令参数（yaml格式数组），例如：["HOSTNAME", "KUBERNETES_PORT"]
|
| 自定义标签 | 作业自定义标签
|
diff --git
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/K8sTaskMainParameters.java
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/K8sTaskMainParameters.java
index ec2b1cab38..d70cf11a22 100644
---
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/K8sTaskMainParameters.java
+++
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/K8sTaskMainParameters.java
@@ -34,6 +34,7 @@ public class K8sTaskMainParameters {
private String args;
private String namespaceName;
private String clusterName;
+ private String imagePullPolicy;
private double minCpuCores;
private double minMemorySpace;
private Map<String, String> paramsMap;
diff --git
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/impl/K8sTaskExecutor.java
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/impl/K8sTaskExecutor.java
index 109304675e..f357713d39 100644
---
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/impl/K8sTaskExecutor.java
+++
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/k8s/impl/K8sTaskExecutor.java
@@ -22,7 +22,6 @@ import static
org.apache.dolphinscheduler.plugin.task.api.TaskConstants.CPU;
import static
org.apache.dolphinscheduler.plugin.task.api.TaskConstants.EXIT_CODE_FAILURE;
import static
org.apache.dolphinscheduler.plugin.task.api.TaskConstants.EXIT_CODE_KILL;
import static
org.apache.dolphinscheduler.plugin.task.api.TaskConstants.EXIT_CODE_SUCCESS;
-import static
org.apache.dolphinscheduler.plugin.task.api.TaskConstants.IMAGE_PULL_POLICY;
import static
org.apache.dolphinscheduler.plugin.task.api.TaskConstants.JOB_TTL_SECONDS;
import static
org.apache.dolphinscheduler.plugin.task.api.TaskConstants.LAYER_LABEL;
import static
org.apache.dolphinscheduler.plugin.task.api.TaskConstants.LAYER_LABEL_VALUE;
@@ -56,6 +55,8 @@ import java.util.concurrent.TimeUnit;
import org.slf4j.Logger;
+import io.fabric8.kubernetes.api.model.Affinity;
+import io.fabric8.kubernetes.api.model.AffinityBuilder;
import io.fabric8.kubernetes.api.model.EnvVar;
import io.fabric8.kubernetes.api.model.NodeSelectorTerm;
import io.fabric8.kubernetes.api.model.Quantity;
@@ -82,6 +83,7 @@ public class K8sTaskExecutor extends AbstractK8sTaskExecutor {
String taskName = taskRequest.getTaskName().toLowerCase(Locale.ROOT);
String image = k8STaskMainParameters.getImage();
String namespaceName = k8STaskMainParameters.getNamespaceName();
+ String imagePullPolicy = k8STaskMainParameters.getImagePullPolicy();
Map<String, String> otherParams = k8STaskMainParameters.getParamsMap();
Double podMem = k8STaskMainParameters.getMinMemorySpace();
Double podCpu = k8STaskMainParameters.getMinCpuCores();
@@ -129,7 +131,16 @@ public class K8sTaskExecutor extends
AbstractK8sTaskExecutor {
NodeSelectorTerm nodeSelectorTerm = new NodeSelectorTerm();
nodeSelectorTerm.setMatchExpressions(k8STaskMainParameters.getNodeSelectorRequirements());
- return new JobBuilder()
+ Affinity affinity =
k8STaskMainParameters.getNodeSelectorRequirements().size() == 0 ? null
+ : new AffinityBuilder()
+ .withNewNodeAffinity()
+
.withNewRequiredDuringSchedulingIgnoredDuringExecution()
+ .addNewNodeSelectorTermLike(nodeSelectorTerm)
+ .endNodeSelectorTerm()
+ .endRequiredDuringSchedulingIgnoredDuringExecution()
+ .endNodeAffinity().build();
+
+ JobBuilder jobBuilder = new JobBuilder()
.withApiVersion(API_VERSION)
.withNewMetadata()
.withName(k8sJobName)
@@ -145,24 +156,18 @@ public class K8sTaskExecutor extends
AbstractK8sTaskExecutor {
.withImage(image)
.withCommand(commands.size() == 0 ? null : commands)
.withArgs(args.size() == 0 ? null : args)
- .withImagePullPolicy(IMAGE_PULL_POLICY)
+ .withImagePullPolicy(imagePullPolicy)
.withResources(new ResourceRequirements(limitRes, reqRes))
.withEnv(envVars)
.endContainer()
.withRestartPolicy(RESTART_POLICY)
- .withNewAffinity()
- .withNewNodeAffinity()
- .withNewRequiredDuringSchedulingIgnoredDuringExecution()
- .addNewNodeSelectorTermLike(nodeSelectorTerm)
- .endNodeSelectorTerm()
- .endRequiredDuringSchedulingIgnoredDuringExecution()
- .endNodeAffinity()
- .endAffinity()
+ .withAffinity(affinity)
.endSpec()
.endTemplate()
.withBackoffLimit(retryNum)
- .endSpec()
- .build();
+ .endSpec();
+
+ return jobBuilder.build();
}
public void registerBatchJobWatcher(Job job, String taskInstanceId,
TaskResponse taskResponse,
diff --git
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/parameters/K8sTaskParameters.java
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/parameters/K8sTaskParameters.java
index be1c5d0c62..fd738fe736 100644
---
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/parameters/K8sTaskParameters.java
+++
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/parameters/K8sTaskParameters.java
@@ -37,11 +37,12 @@ public class K8sTaskParameters extends AbstractParameters {
private String image;
private String namespace;
private String command;
- private List<Label> customizedLabels;
- private List<NodeSelectorExpression> nodeSelectors;
private String args;
+ private String imagePullPolicy;
private double minCpuCores;
private double minMemorySpace;
+ private List<Label> customizedLabels;
+ private List<NodeSelectorExpression> nodeSelectors;
@Override
public boolean checkParameters() {
diff --git
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/test/java/org/apache/dolphinscheduler/plugin/task/api/k8s/K8sTaskExecutorTest.java
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/test/java/org/apache/dolphinscheduler/plugin/task/api/k8s/K8sTaskExecutorTest.java
index 5ee023f1bc..9931a33ae5 100644
---
a/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/test/java/org/apache/dolphinscheduler/plugin/task/api/k8s/K8sTaskExecutorTest.java
+++
b/dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/test/java/org/apache/dolphinscheduler/plugin/task/api/k8s/K8sTaskExecutorTest.java
@@ -44,6 +44,7 @@ public class K8sTaskExecutorTest {
private K8sTaskExecutor k8sTaskExecutor = null;
private K8sTaskMainParameters k8sTaskMainParameters = null;
private final String image = "ds-dev";
+ private final String imagePullPolicy = "IfNotPresent";
private final String namespace =
"{\"name\":\"default\",\"cluster\":\"lab\"}";
private final double minCpuCores = 2;
private final double minMemorySpace = 10;
@@ -68,6 +69,7 @@ public class K8sTaskExecutorTest {
k8sTaskExecutor = new K8sTaskExecutor(null, taskRequest);
k8sTaskMainParameters = new K8sTaskMainParameters();
k8sTaskMainParameters.setImage(image);
+ k8sTaskMainParameters.setImagePullPolicy(imagePullPolicy);
k8sTaskMainParameters.setNamespaceName(namespaceName);
k8sTaskMainParameters.setClusterName(clusterName);
k8sTaskMainParameters.setMinCpuCores(minCpuCores);
diff --git
a/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/main/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sTask.java
b/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/main/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sTask.java
index 35e7854bab..9c5e249b06 100644
---
a/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/main/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sTask.java
+++
b/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/main/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sTask.java
@@ -97,6 +97,7 @@ public class K8sTask extends AbstractK8sTask {
.setNodeSelectorRequirements(convertToNodeSelectorRequirements(k8sTaskParameters.getNodeSelectors()));
k8sTaskMainParameters.setCommand(k8sTaskParameters.getCommand());
k8sTaskMainParameters.setArgs(k8sTaskParameters.getArgs());
+
k8sTaskMainParameters.setImagePullPolicy(k8sTaskParameters.getImagePullPolicy());
return JSONUtils.toJsonString(k8sTaskMainParameters);
}
diff --git
a/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/test/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sParametersTest.java
b/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/test/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sParametersTest.java
index 45707f3f48..eb65ede9d0 100644
---
a/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/test/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sParametersTest.java
+++
b/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/test/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sParametersTest.java
@@ -32,6 +32,7 @@ public class K8sParametersTest {
private K8sTaskParameters k8sTaskParameters = null;
private final String image = "ds-dev";
+ private final String imagePullPolicy = "IfNotPresent";
private final String namespace =
"{\"name\":\"default\",\"cluster\":\"lab\"}";
private final double minCpuCores = 2;
private final double minMemorySpace = 10;
@@ -45,6 +46,7 @@ public class K8sParametersTest {
public void before() {
k8sTaskParameters = new K8sTaskParameters();
k8sTaskParameters.setImage(image);
+ k8sTaskParameters.setImagePullPolicy(imagePullPolicy);
k8sTaskParameters.setNamespace(namespace);
k8sTaskParameters.setMinCpuCores(minCpuCores);
k8sTaskParameters.setMinMemorySpace(minMemorySpace);
@@ -68,6 +70,7 @@ public class K8sParametersTest {
@Test
public void testK8sParameters() {
Assertions.assertEquals(image, k8sTaskParameters.getImage());
+ Assertions.assertEquals(imagePullPolicy,
k8sTaskParameters.getImagePullPolicy());
Assertions.assertEquals(namespace, k8sTaskParameters.getNamespace());
Assertions.assertEquals(0, Double.compare(minCpuCores,
k8sTaskParameters.getMinCpuCores()));
Assertions.assertEquals(0, Double.compare(minMemorySpace,
k8sTaskParameters.getMinMemorySpace()));
diff --git
a/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/test/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sTaskTest.java
b/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/test/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sTaskTest.java
index a0fda89e33..93b6f85e5a 100644
---
a/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/test/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sTaskTest.java
+++
b/dolphinscheduler-task-plugin/dolphinscheduler-task-k8s/src/test/java/org/apache/dolphinscheduler/plugin/task/k8s/K8sTaskTest.java
@@ -44,6 +44,7 @@ public class K8sTaskTest {
private K8sTask k8sTask = null;
private final String image = "ds-dev";
+ private final String imagePullPolicy = "IfNotPresent";
private final String namespace =
"{\"name\":\"default\",\"cluster\":\"lab\"}";
@@ -65,6 +66,7 @@ public class K8sTaskTest {
public void before() {
k8sTaskParameters = new K8sTaskParameters();
k8sTaskParameters.setImage(image);
+ k8sTaskParameters.setImagePullPolicy(imagePullPolicy);
k8sTaskParameters.setNamespace(namespace);
k8sTaskParameters.setMinCpuCores(minCpuCores);
k8sTaskParameters.setMinMemorySpace(minMemorySpace);
@@ -97,7 +99,7 @@ public class K8sTaskTest {
@Test
public void testBuildCommandNormal() {
String expectedStr =
- "{\"image\":\"ds-dev\",\"command\":\"[\\\"/bin/bash\\\",
\\\"-c\\\"]\",\"args\":\"[\\\"echo hello
world\\\"]\",\"namespaceName\":\"default\",\"clusterName\":\"lab\",\"minCpuCores\":2.0,\"minMemorySpace\":10.0,\"paramsMap\":{\"day\":\"20220507\"},\"labelMap\":{\"test\":\"1234\"},\"nodeSelectorRequirements\":[{\"key\":\"node-label\",\"operator\":\"In\",\"values\":[\"1234\",\"12345\"]}]}";
+ "{\"image\":\"ds-dev\",\"command\":\"[\\\"/bin/bash\\\",
\\\"-c\\\"]\",\"args\":\"[\\\"echo hello
world\\\"]\",\"namespaceName\":\"default\",\"clusterName\":\"lab\",\"imagePullPolicy\":\"IfNotPresent\",\"minCpuCores\":2.0,\"minMemorySpace\":10.0,\"paramsMap\":{\"day\":\"20220507\"},\"labelMap\":{\"test\":\"1234\"},\"nodeSelectorRequirements\":[{\"key\":\"node-label\",\"operator\":\"In\",\"values\":[\"1234\",\"12345\"]}]}";
String commandStr = k8sTask.buildCommand();
Assertions.assertEquals(expectedStr, commandStr);
}
@@ -105,7 +107,7 @@ public class K8sTaskTest {
@Test
public void testGetParametersNormal() {
String expectedStr =
- "K8sTaskParameters(image=ds-dev,
namespace={\"name\":\"default\",\"cluster\":\"lab\"}, command=[\"/bin/bash\",
\"-c\"], customizedLabels=[Label(label=test, value=1234)],
nodeSelectors=[NodeSelectorExpression(key=node-label, operator=In,
values=1234,12345)], args=[\"echo hello world\"], minCpuCores=2.0,
minMemorySpace=10.0)";
+ "K8sTaskParameters(image=ds-dev,
namespace={\"name\":\"default\",\"cluster\":\"lab\"}, command=[\"/bin/bash\",
\"-c\"], args=[\"echo hello world\"], imagePullPolicy=IfNotPresent,
minCpuCores=2.0, minMemorySpace=10.0, customizedLabels=[Label(label=test,
value=1234)], nodeSelectors=[NodeSelectorExpression(key=node-label,
operator=In, values=1234,12345)])";
String result = k8sTask.getParameters().toString();
Assertions.assertEquals(expectedStr, result);
}
diff --git a/dolphinscheduler-ui/src/locales/en_US/project.ts
b/dolphinscheduler-ui/src/locales/en_US/project.ts
index 363a8a858a..fa69010413 100644
--- a/dolphinscheduler-ui/src/locales/en_US/project.ts
+++ b/dolphinscheduler-ui/src/locales/en_US/project.ts
@@ -386,6 +386,8 @@ export default {
mb: 'MB',
image: 'Image',
image_tips: 'Please enter image',
+ image_pull_policy: 'Image pull policy',
+ image_pull_policy_tips: 'Please select a image pull policy (required)',
command: 'Command',
command_tips:
'Please enter the container execution command, for example:
["printenv"]',
diff --git a/dolphinscheduler-ui/src/locales/zh_CN/project.ts
b/dolphinscheduler-ui/src/locales/zh_CN/project.ts
index 5f5f6e299c..20d1bb8993 100644
--- a/dolphinscheduler-ui/src/locales/zh_CN/project.ts
+++ b/dolphinscheduler-ui/src/locales/zh_CN/project.ts
@@ -385,6 +385,8 @@ export default {
mb: 'MB',
image: '镜像',
image_tips: '请输入镜像',
+ image_pull_policy: '镜像拉取策略',
+ image_pull_policy_tips: '请选择镜像拉取策略（必选）',
command: '容器执行命令',
command_tips: '请输入容器执行命令，例如：["printenv"]',
args: '执行命令参数',
diff --git
a/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-k8s.ts
b/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-k8s.ts
index dd0a4a3d8d..390ab2808c 100644
---
a/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-k8s.ts
+++
b/dolphinscheduler-ui/src/views/projects/task/components/node/fields/use-k8s.ts
@@ -56,12 +56,26 @@ export function useK8s(model: { [field: string]: any }):
IJsonItem[] {
type: 'input',
field: 'image',
name: t('project.node.image'),
+ span: 18,
props: {
placeholder: t('project.node.image_tips')
},
validate: {
trigger: ['input', 'blur'],
- message: t('project.node.min_memory_tips')
+ required: true,
+ message: t('project.node.image_tips')
+ }
+ },
+ {
+ type: 'select',
+ field: 'imagePullPolicy',
+ name: t('project.node.image_pull_policy'),
+ span: 6,
+ options: IMAGE_PULL_POLICY_LIST,
+ validate: {
+ trigger: ['input', 'blur'],
+ required: true,
+ message: t('project.node.image_pull_policy_tips')
}
},
{
@@ -93,3 +107,19 @@ export function useK8s(model: { [field: string]: any }):
IJsonItem[] {
...useCustomParams({ model, field: 'localParams', isSimple: true })
]
}
+
+
+export const IMAGE_PULL_POLICY_LIST = [
+ {
+ value: 'IfNotPresent',
+ label: 'IfNotPresent'
+ },
+ {
+ value: 'Always',
+ label: 'Always'
+ },
+ {
+ value: 'Never',
+ label: 'Never'
+ }
+]
diff --git
a/dolphinscheduler-ui/src/views/projects/task/components/node/format-data.ts
b/dolphinscheduler-ui/src/views/projects/task/components/node/format-data.ts
index 619992640e..914c1edb12 100644
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/format-data.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/format-data.ts
@@ -347,6 +347,7 @@ export function formatParams(data: INodeData): {
taskParams.minCpuCores = data.minCpuCores
taskParams.minMemorySpace = data.minMemorySpace
taskParams.image = data.image
+ taskParams.imagePullPolicy = data.imagePullPolicy
taskParams.command = data.command
taskParams.args = data.args
taskParams.customizedLabels = data.customizedLabels
diff --git
a/dolphinscheduler-ui/src/views/projects/task/components/node/types.ts
b/dolphinscheduler-ui/src/views/projects/task/components/node/types.ts
index df8d3b6f1e..e67eecb4f0 100644
--- a/dolphinscheduler-ui/src/views/projects/task/components/node/types.ts
+++ b/dolphinscheduler-ui/src/views/projects/task/components/node/types.ts
@@ -370,6 +370,7 @@ interface ITaskParams {
minCpuCores?: string
minMemorySpace?: string
image?: string
+ imagePullPolicy?: string
command?: string
args?: string
customizedLabels?: ILabel[]
