From 01ea9a123ca6cdcaf3ea47a71dd7a44e5d9f4e43 Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Mon, 29 Jan 2024 22:48:46 +0800 Subject: [PATCH] fix --- src/stream/src/executor/backfill/arrangement_backfill.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/stream/src/executor/backfill/arrangement_backfill.rs b/src/stream/src/executor/backfill/arrangement_backfill.rs index f7e5d35f6475e..adc3233d2d42e 100644 --- a/src/stream/src/executor/backfill/arrangement_backfill.rs +++ b/src/stream/src/executor/backfill/arrangement_backfill.rs @@ -222,7 +222,7 @@ where 'backfill_loop: loop { let mut cur_barrier_snapshot_processed_rows: u64 = 0; let mut cur_barrier_upstream_processed_rows: u64 = 0; - let mut snapshot_read_complete = true; + let mut snapshot_read_complete = false; let mut has_snapshot_read = false; // NOTE(kwannoel): Scope it so that immutable reference to `upstream_table` can be