fix: processor concurrency issue on startup (#2328)

---------

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

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java

@@ -400,7 +400,8 @@ public synchronized void stop() {
   }
 
   @Override
-  public void start() throws OperatorException {
+  public synchronized void start() throws OperatorException {
+    log.debug("Starting event processor: {}", this);
     // on restart new executor service is created and needs to be set here
     executor = controllerConfiguration.getConfigurationService().getExecutorServiceManager()
         .reconcileExecutorService();
@@ -410,6 +411,7 @@ public void start() throws OperatorException {
 
   private void handleAlreadyMarkedEvents() {
     for (var state : resourceStateManager.resourcesWithEventPresent()) {
+      log.debug("Handling already marked event on start. State: {}", state);
       handleMarkedEventForResource(state);
     }
   }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/ReconciliationDispatcher.java

@@ -71,7 +71,8 @@ private PostExecutionControl<P> handleDispatch(ExecutionScope<P> executionScope)
       throws Exception {
     P originalResource = executionScope.getResource();
     var resourceForExecution = cloneResource(originalResource);
-    log.debug("Handling dispatch for resource {}", getName(originalResource));
+    log.debug("Handling dispatch for resource name: {} namespace: {}", getName(originalResource),
+        originalResource.getMetadata().getNamespace());
 
     final var markedForDeletion = originalResource.isMarkedForDeletion();
     if (markedForDeletion && shouldNotDispatchToCleanupWhenMarkedForDeletion(originalResource)) {

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/ResourceState.java

@@ -111,4 +111,15 @@ public void unMarkEventReceived() {
         break;
     }
   }
+
+  @Override
+  public String toString() {
+    return "ResourceState{" +
+        "id=" + id +
+        ", underProcessing=" + underProcessing +
+        ", retry=" + retry +
+        ", eventing=" + eventing +
+        ", rateLimit=" + rateLimit +
+        '}';
+  }
 }