fix: flow source break on empty chnl

GreptimeTeam · May 30, 2024 · e183323 · e183323
1 parent 41d0a12
commit e183323
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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;