wip

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

@@ -267,7 +267,7 @@ public Set<R> getSecondaryResources(P primary) {
           primary.getMetadata().getNamespace(),
           resources.size(),
           sid,
-          manager().list());
+          manager().list().toList());
 
       log.debug("Complementary ids: {}", temporalIds);
       var res =

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

@@ -73,6 +73,10 @@ synchronized void onEvent(T resource, boolean unknownState) {
             (id, cached) ->
                 (unknownState || !isLaterResourceVersion(id, cached, resource)) ? null : cached);
     if (res == null) {
+      log.debug(
+          "Cleaning up for resource name: {} ns: {} ",
+          resource.getMetadata().getName(),
+          resource.getMetadata().getNamespace());
       temporalPrimaryToSecondaryIndex.cleanupForResource(resource);
     }
   }

operator-framework/src/test/java/io/javaoperatorsdk/operator/dependent/dependentresourcecrossref/DependentResourceCrossRefIT.java

@@ -16,7 +16,7 @@
 class DependentResourceCrossRefIT {
 
   public static final String TEST_RESOURCE_NAME = "test";
-  public static final int EXECUTION_NUMBER = 10;
+  public static final int EXECUTION_NUMBER = 5250;
 
   @RegisterExtension
   LocallyRunOperatorExtension operator =

operator-framework/src/test/java/io/javaoperatorsdk/operator/dependent/dependentresourcecrossref/DependentResourceCrossRefReconciler.java

@@ -53,7 +53,7 @@ public ErrorStatusUpdateControl<DependentResourceCrossRefResource> updateErrorSt
       DependentResourceCrossRefResource resource,
       Context<DependentResourceCrossRefResource> context,
       Exception e) {
-    log.error("Status update on error", e);
+    log.error("Status update on error for resource: {}", resource.getMetadata().getName(), e);
     errorHappened = true;
     return ErrorStatusUpdateControl.noStatusUpdate();
   }