From 3feb4d325160aaf3f42b58963b7110605c8b0fa7 Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Fri, 19 May 2023 20:40:15 +0800 Subject: [PATCH] if snapshot empty still finish --- src/stream/src/executor/backfill.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/stream/src/executor/backfill.rs b/src/stream/src/executor/backfill.rs index 229ac599076b5..233be586fec21 100644 --- a/src/stream/src/executor/backfill.rs +++ b/src/stream/src/executor/backfill.rs @@ -168,7 +168,7 @@ where // Whether we still need to backfill let to_backfill = !is_finished && !is_snapshot_empty; - if !to_backfill { + if !is_finished && is_snapshot_empty { // Directly finish the progress as the snapshot is empty. self.progress.finish(first_barrier.epoch.curr); }