We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8f69a5e commit 1cc04d7Copy full SHA for 1cc04d7
operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java
@@ -501,13 +501,8 @@ public void run() {
501
.filter(ResourceState::deleteEventPresent)
502
.map(ResourceState::getLastKnownResource);
503
if (actualResource.isEmpty()) {
504
- log.debug(
505
- "Skipping execution; delete event resource not found in state: {}", resourceID);
506
- return;
+ throw new IllegalStateException("This should not happen");
507
}
508
- } else {
509
- log.debug("Skipping execution; primary resource missing from cache: {}", resourceID);
510
511
512
513
actualResource.ifPresent(executionScope::setResource);
0 commit comments