From 12f06d51beed5863d21e81570e7498bb11721587 Mon Sep 17 00:00:00 2001
From: discord9 <discord9@163.com>
Date: Wed, 29 May 2024 20:01:58 +0800
Subject: [PATCH] fix: flow source break on empty chnl

---
 src/flow/src/compute/render/src_sink.rs | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/flow/src/compute/render/src_sink.rs b/src/flow/src/compute/render/src_sink.rs
index 9fed1c415305..96411b6d04b0 100644
--- a/src/flow/src/compute/render/src_sink.rs
+++ b/src/flow/src/compute/render/src_sink.rs
@@ -76,6 +76,9 @@ impl<'referred, 'df> Context<'referred, 'df> {
                                 to_arrange.push(((r, Row::empty()), t, d));
                             }
                         }
+                        Err(TryRecvError::Empty) => {
+                            break;
+                        }
                         Err(TryRecvError::Lagged(lag_offset)) => {
                             common_telemetry::error!("Flow missing {} rows behind", lag_offset);
                             break;