Skip to content

Commit c5e1b01

Browse files
committed
Fix usage of deprectaed method createOrUpdate from fabric8
Signed-off-by: David Kornel <[email protected]>
1 parent eb1780b commit c5e1b01

File tree

1 file changed

+5
-1
lines changed
  • examples/kubernetes-client-examples/src/main/java/org/apache/flink/examples

1 file changed

+5
-1
lines changed

examples/kubernetes-client-examples/src/main/java/org/apache/flink/examples/Basic.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,11 @@ public static void main(String[] args) {
6868
.build());
6969

7070
try (KubernetesClient kubernetesClient = new KubernetesClientBuilder().build()) {
71-
kubernetesClient.resource(flinkDeployment).createOrReplace();
71+
if (kubernetesClient.resource(flinkDeployment).get() == null) {
72+
kubernetesClient.resource(flinkDeployment).create();
73+
} else {
74+
kubernetesClient.resource(flinkDeployment).update();
75+
}
7276
}
7377
}
7478
}

0 commit comments

Comments
 (0)