natas_hw
/
dolphinscheduler0701
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Improvement-12372][k8s] Update the deprecated k8s api (#12373)

This commit is contained in:
rickchengx 2022-10-14 16:18:35 +08:00 committed by zhuangchong
parent 39c1144fab
commit 5cfe6a96b4
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
dolphinscheduler-task-plugin/dolphinscheduler-task-api/src/main/java/org/apache/dolphinscheduler/plugin/task/api/utils/K8sUtils.java
View File

@ -44,6 +44,7 @@ public class K8sUtils {
public void createJob(String namespace, Job job) {
try {
client.batch()
.v1()
.jobs()
.inNamespace(namespace)
.create(job);
@ -55,6 +56,7 @@ public class K8sUtils {
public void deleteJob(String jobName, String namespace) {
try {
client.batch()
.v1()
.jobs()
.inNamespace(namespace)
.withName(jobName)
@ -81,7 +83,10 @@ public class K8sUtils {
public Watch createBatchJobWatcher(String jobName, Watcher<Job> watcher) {
try {
return client.batch()
.jobs().withName(jobName).watch(watcher);
.v1()
.jobs()
.withName(jobName)
.watch(watcher);
} catch (Exception e) {
throw new TaskException("fail to register batch job watcher", e);
}