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/ManagedInformerEventSource.java

@@ -186,15 +186,12 @@ public void handleRecentResourceCreate(ResourceID resourceID, R resource) {
 
   @Override
   public Optional<R> get(ResourceID resourceID) {
-    // The order of these two lookups matters. If we queried the informer cache first,
-    // a race condition could occur: we might not find the resource there yet, then
-    // process an informer event that evicts the temporary resource cache entry. At that
-    // point the resource would already be present in the informer cache, but we would
-    // have missed it in both caches during this call.
-    Optional<R> resource = temporaryResourceCache.getResourceFromCache(resourceID);
-    if (comparableResourceVersions && resource.isPresent()) {
-      log.debug("Latest resource found in temporary cache for Resource ID: {}", resourceID);
-      return resource;
+    if (comparableResourceVersions) {
+      Optional<R> resource = temporaryResourceCache.getResourceFromCache(resourceID);
+      if (resource.isPresent()) {
+        log.debug("Latest resource found in temporary cache for Resource ID: {}", resourceID);
+        return resource;
+      }
     }
     var res = cache.get(resourceID);
     log.debug(

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

@@ -263,7 +263,7 @@ private void setLatestResourceVersion(T resource) {
     } else {
       perNamespaceLatestResourceVersion.put(
           resource.getMetadata().getNamespace(), resource.getMetadata().getResourceVersion());
-      log.debug("Setting latest resource version to: {} for namesoace", latestResourceVersion);
+      log.debug("Setting latest resource version to: {} for namespace", latestResourceVersion);
     }
   }