diff --git a/dozer-core/src/executor/sink_node.rs b/dozer-core/src/executor/sink_node.rs
index 1d3a07792e..5cae3485e4 100644
--- a/dozer-core/src/executor/sink_node.rs
+++ b/dozer-core/src/executor/sink_node.rs
@@ -240,6 +240,7 @@ impl ReceiverLoop for SinkNode {
                 } else {
                     self.flush_scheduled_on_next_commit = true;
                 }
+                continue;
             }
             let op = receivers[index]
                 .recv()