log msg

Signed-off-by: Attila Mészáros <[email protected]>

Author: csviri

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

@@ -253,18 +253,20 @@ public Set<R> getSecondaryResources(P primary) {
       // that we did not receive yet an event in the informer so the index would not
       // be updated. However, before reading it from temp IDs the event arrives and erases
       // the temp index. So in case of Add not id would be found.
+      var sid = resourceIdToString(primaryID);
       var temporalIds =
           temporaryResourceCache
               .getTemporalPrimaryToSecondaryIndex()
               .getSecondaryResources(primaryID);
-      var resources = byIndex(PRIMARY_TO_SECONDARY_INDEX_NAME, resourceIdToString(primaryID));
+      var resources = byIndex(PRIMARY_TO_SECONDARY_INDEX_NAME, sid);
 
       log.debug(
           "Using informer primary to secondary index to find secondary resources for primary name:"
-              + " {} namespace: {}. Found number {}",
+              + " {} namespace: {}. Found number {}, String id: {}",
           primary.getMetadata().getName(),
           primary.getMetadata().getNamespace(),
-          resources.size());
+          resources.size(),
+          sid);
 
       log.debug("Complementary ids: {}", temporalIds);
       var res =

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

@@ -93,7 +93,7 @@ public synchronized void putResource(T newResource, String previousResourceVersi
     }
     var resourceId = ResourceID.fromResource(newResource);
     var cachedResource = managedInformerEventSource.get(resourceId).orElse(null);
-    temporalPrimaryToSecondaryIndex.explicitAddOrUpdate(newResource);
+
     boolean moveAhead = false;
     if (previousResourceVersion == null && cachedResource == null) {
       if (tombstones.contains(newResource.getMetadata().getUid())) {
@@ -107,7 +107,6 @@ public synchronized void putResource(T newResource, String previousResourceVersi
       // consider
       moveAhead = true;
     }
-
     if (moveAhead
         || (cachedResource != null
                 && (cachedResource
@@ -119,7 +118,7 @@ public synchronized void putResource(T newResource, String previousResourceVersi
           "Temporarily moving ahead to target version {} for resource id: {}",
           newResource.getMetadata().getResourceVersion(),
           resourceId);
-
+      temporalPrimaryToSecondaryIndex.explicitAddOrUpdate(newResource);
       cache.put(resourceId, newResource);
     } else if (cache.remove(resourceId) != null) {
       log.debug("Removed an obsolete resource from cache for id: {}", resourceId);