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 b068d1d commit 05fa975Copy full SHA for 05fa975
operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java
@@ -247,7 +247,7 @@ synchronized void eventProcessingFinished(
247
// Either way we don't want to retry.
248
if (isRetryConfigured()
249
&& postExecutionControl.exceptionDuringExecution()
250
- && !state.deleteEventPresent()) {
+ && (!state.deleteEventPresent() || controllerConfiguration.isAllEventReconcileMode())) {
251
handleRetryOnException(
252
executionScope, postExecutionControl.getRuntimeException().orElseThrow());
253
return;
0 commit comments