diff --git a/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java b/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java
index dcc7f59..e7f3ef6 100644
--- a/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java
+++ b/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java
@@ -635,17 +635,18 @@
                 break;
 
             case BATCH_OPERATION_COMPLETED:
-
+                // Operation completed, let's retrieve the processor and trigger the callback
                 FlowOperationsProcessor fops = pendingFlowOperations.remove(
                         event.subject().batchId());
-                if (event.result().isSuccess()) {
-                    if (fops != null) {
+                if (fops != null) {
+                    if (event.result().isSuccess()) {
                         fops.satisfy(event.deviceId());
+                    } else {
+                        fops.fail(event.deviceId(), event.result().failedItems());
                     }
                 } else {
-                    fops.fail(event.deviceId(), event.result().failedItems());
+                    log.warn("Unable to find flow operations processor for batch: {}", event.subject().batchId());
                 }
-
                 break;
 
             default: