wip

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerEventSource.java

@@ -195,20 +195,6 @@ private synchronized void onAddOrUpdate(
 
   private boolean canSkipEvent(R newObject, R oldObject, ResourceID resourceID) {
     return !temporaryResourceCache.isNewerThenKnownResource(newObject, resourceID);
-    //    if (res.isEmpty()) {
-    //      return false;
-    //    }
-    //    boolean resVersionsEqual =
-    //        newObject
-    //            .getMetadata()
-    //            .getResourceVersion()
-    //            .equals(res.get().getMetadata().getResourceVersion());
-    //    log.debug(
-    //        "Resource found in temporal cache for id: {} resource versions equal: {}",
-    //        resourceID,
-    //        resVersionsEqual);
-    //    return resVersionsEqual || temporaryResourceCache.isLaterResourceVersion(res.get(),
-    // newObject);
   }
 
   private void propagateEvent(R object) {

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/TemporaryResourceCache.java

@@ -151,10 +151,17 @@ public synchronized void putResource(T newResource, String previousResourceVersi
           newResource.getMetadata().getResourceVersion(),
           resourceId);
       cache.put(resourceId, newResource);
-    } else if (cache.remove(resourceId) != null) {
-      log.debug("Removed an obsolete resource from cache for id: {}", resourceId);
-      latestUpdatedVersion.put(
-          resourceId, Long.parseLong(newResource.getMetadata().getResourceVersion()));
+    } else {
+      if (newResource
+          .getMetadata()
+          .getResourceVersion()
+          .equals(cachedResource.getMetadata().getResourceVersion())) {
+        latestUpdatedVersion.put(
+            resourceId, Long.parseLong(newResource.getMetadata().getResourceVersion()));
+      }
+      if (cache.remove(resourceId) != null) {
+        log.debug("Removed an obsolete resource from cache for id: {}", resourceId);
+      }
     }
   }