Kubernetes Operator for Nessie

projectnessie · Jan 25, 2024 · bd00481 · bd00481
1 parent 7980621
commit bd00481
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/operator/src/main/java/org/projectnessie/operator/helper/EventsHelper.java b/operator/src/main/java/org/projectnessie/operator/helper/EventsHelper.java
@@ -22,6 +22,7 @@
 import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
 import io.fabric8.kubernetes.api.model.ObjectReferenceBuilder;
 import io.fabric8.kubernetes.client.KubernetesClient;
+import io.fabric8.kubernetes.client.dsl.NonDeletingOperation;
 import io.javaoperatorsdk.operator.api.reconciler.Context;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.inject.Inject;
@@ -113,7 +114,7 @@ public synchronized void fireEvent(
               .build();
       LOGGER.debug("Creating event {}", event.getMetadata().getName());
       try {
-        client.v1().events().resource(event).create();
+        client.v1().events().resource(event).createOr(NonDeletingOperation::patch);
         eventsCache.get(nessie.getMetadata().getUid()).put(reason, event);
       } catch (Exception e) {
         LOGGER.warn("Failed to create event {}", event, e);