IT fix

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

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/kubernetes/KubernetesDependentConverter.java

@@ -3,6 +3,9 @@
 import java.lang.reflect.InvocationTargetException;
 import java.util.Set;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import io.fabric8.kubernetes.api.model.GenericKubernetesResource;
 import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
@@ -26,6 +29,8 @@
 public class KubernetesDependentConverter<R extends HasMetadata, P extends HasMetadata> implements
     ConfigurationConverter<KubernetesDependent, KubernetesDependentResourceConfig<R>> {
 
+  private static final Logger log = LoggerFactory.getLogger(KubernetesDependentConverter.class);
+
   @Override
   @SuppressWarnings({"unchecked", "rawtypes"})
   public KubernetesDependentResourceConfig<R> configFrom(KubernetesDependent configAnnotation,
@@ -135,12 +140,14 @@ private InformerConfiguration<R> createInformerConfiguration(KubernetesDependent
           informerConfig.withSecondaryToPrimaryMapper(secondaryToPrimaryMapper);
         }
       } else {
-        var mapper = getSecondaryToPrimaryMapper(dependentResourceClass,
-            controllerConfig.getResourceClass()).orElseThrow(
-                () -> new IllegalStateException(
-                    "No suitable SecondaryToPrimaryMapper for informer of dependent resource: "
-                        + dependentResourceClass.getName()));
-        informerConfig.withSecondaryToPrimaryMapper(mapper);
+        getSecondaryToPrimaryMapper(dependentResourceClass,
+            controllerConfig.getResourceClass())
+            .ifPresentOrElse(informerConfig::withSecondaryToPrimaryMapper, () -> {
+              if (spec.getUseEventSourceWithName().isEmpty()) {
+                log.warn("No SecondaryToPrimaryMapper going to be set for dependent resource." +
+                    " This might be an issue with the setup of the dependent resource");
+              }
+            });
       }
 
 

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/primaryindexer/DependentPrimaryIndexerTestReconciler.java

@@ -18,13 +18,17 @@
 import io.javaoperatorsdk.operator.processing.event.source.EventSource;
 import io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource;
 
-@Workflow(dependents = @Dependent(
+import static io.javaoperatorsdk.operator.sample.primaryindexer.DependentPrimaryIndexerTestReconciler.CONFIG_MAP_EVENT_SOURCE;
+
+@Workflow(dependents = @Dependent(useEventSourceWithName = CONFIG_MAP_EVENT_SOURCE,
     type = DependentPrimaryIndexerTestReconciler.ReadOnlyConfigMapDependent.class))
 @ControllerConfiguration
 public class DependentPrimaryIndexerTestReconciler extends AbstractPrimaryIndexerTestReconciler
     implements
     Reconciler<PrimaryIndexerTestCustomResource> {
 
+  public static final String CONFIG_MAP_EVENT_SOURCE = "configMapEventSource";
+
   @Override
   public List<EventSource> prepareEventSources(
       EventSourceContext<PrimaryIndexerTestCustomResource> context) {
@@ -35,6 +39,7 @@ public List<EventSource> prepareEventSources(
     InformerEventSource<ConfigMap, PrimaryIndexerTestCustomResource> es =
         new InformerEventSource<>(
             InformerConfiguration.from(ConfigMap.class, PrimaryIndexerTestCustomResource.class)
+                .withName(CONFIG_MAP_EVENT_SOURCE)
                 .withSecondaryToPrimaryMapper(resource -> cache
                     .byIndex(CONFIG_MAP_RELATION_INDEXER, resource.getMetadata().getName())
                     .stream()