File tree Expand file tree Collapse file tree 1 file changed +2
-5
lines changed
examples/kubernetes-client-examples/src/main/java/org/apache/flink/examples Expand file tree Collapse file tree 1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change 2929import io .fabric8 .kubernetes .api .model .ObjectMeta ;
3030import io .fabric8 .kubernetes .client .KubernetesClient ;
3131import io .fabric8 .kubernetes .client .KubernetesClientBuilder ;
32+ import io .fabric8 .kubernetes .client .dsl .NonDeletingOperation ;
3233
3334import java .util .Map ;
3435
@@ -68,11 +69,7 @@ public static void main(String[] args) {
6869 .build ());
6970
7071 try (KubernetesClient kubernetesClient = new KubernetesClientBuilder ().build ()) {
71- if (kubernetesClient .resource (flinkDeployment ).get () == null ) {
72- kubernetesClient .resource (flinkDeployment ).create ();
73- } else {
74- kubernetesClient .resource (flinkDeployment ).update ();
75- }
72+ kubernetesClient .resource (flinkDeployment ).createOr (NonDeletingOperation ::update );
7673 }
7774 }
7875}
You can’t perform that action at this time.
0 commit comments