diff --git a/examples/kubernetes-client-examples/src/main/java/org/apache/flink/examples/Basic.java b/examples/kubernetes-client-examples/src/main/java/org/apache/flink/examples/Basic.java
index f4fb0ae1ca..497b68a0e2 100644
--- a/examples/kubernetes-client-examples/src/main/java/org/apache/flink/examples/Basic.java
+++ b/examples/kubernetes-client-examples/src/main/java/org/apache/flink/examples/Basic.java
@@ -68,7 +68,11 @@ public static void main(String[] args) {
                                 .build());
 
         try (KubernetesClient kubernetesClient = new KubernetesClientBuilder().build()) {
-            kubernetesClient.resource(flinkDeployment).createOrReplace();
+            if (kubernetesClient.resource(flinkDeployment).get() == null) {
+                kubernetesClient.resource(flinkDeployment).create();
+            } else {
+                kubernetesClient.resource(flinkDeployment).update();
+            }
         }
     }
 }