From 225ada236e60597d78ec34b0ca0b6cf2624e7937 Mon Sep 17 00:00:00 2001
From: Micah Wylde <micah@arroyo.systems>
Date: Fri, 27 Dec 2024 16:14:00 -0800
Subject: [PATCH] Address log message spew when committing multiple sinks
 (#817)

---
 crates/arroyo-operator/src/operator.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/crates/arroyo-operator/src/operator.rs b/crates/arroyo-operator/src/operator.rs
index 179d8dcc9..d34eaf4ff 100644
--- a/crates/arroyo-operator/src/operator.rs
+++ b/crates/arroyo-operator/src/operator.rs
@@ -919,7 +919,7 @@ async fn operator_run_behavior(
                 }
             }
 
-            p = sel.next() => {
+            p = sel.next(), if !shutdown_after_commit => {
                 match p {
                     Some(((idx, message), s)) => {
                         let local_idx = idx;