wip

csviri · csviri · commit 4d38633deb6a · 2025-12-27T14:36:24.000+01:00
Signed-off-by: Attila Mészáros &lt;a_meszaros@apple.com&gt;
diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/TemporaryResourceCache.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/TemporaryResourceCache.java
@@ -128,7 +128,7 @@ private synchronized boolean onEvent(T resource, boolean unknownState, boolean d
       latestResourceVersion = resource.getMetadata().getResourceVersion();
     }
     var cached = cache.get(resourceId);
-    boolean filterEvent = true;
+    boolean filterEvent = false;
     int comp = 0;
     if (cached != null) {
       comp = ReconcileUtils.compareResourceVersions(resource, cached);
@@ -138,6 +138,8 @@ private synchronized boolean onEvent(T resource, boolean unknownState, boolean d
         // will receive
         // additional event
         filterEvent = false;
+      } else {
+        filterEvent = true;
       }
     }
     var ed = activeUpdates.get(resourceId);

Original file line number	Diff line number	Diff line change
`@@ -128,7 +128,7 @@ private synchronized boolean onEvent(T resource, boolean unknownState, boolean d`
`128`	`128`	`latestResourceVersion = resource.getMetadata().getResourceVersion();`
`129`	`129`	`}`
`130`	`130`	`var cached = cache.get(resourceId);`
`131`		`- boolean filterEvent = true;`
	`131`	`+ boolean filterEvent = false;`
`132`	`132`	`int comp = 0;`
`133`	`133`	`if (cached != null) {`
`134`	`134`	`comp = ReconcileUtils.compareResourceVersions(resource, cached);`
`@@ -138,6 +138,8 @@ private synchronized boolean onEvent(T resource, boolean unknownState, boolean d`
`138`	`138`	`// will receive`
`139`	`139`	`// additional event`
`140`	`140`	`filterEvent = false;`
	`141`	`+ } else {`
	`142`	`+ filterEvent = true;`
`141`	`143`	`}`
`142`	`144`	`}`
`143`	`145`	`var ed = activeUpdates.get(resourceId);`