if snapshot empty still finish

risingwavelabs · May 19, 2023 · 3feb4d3 · 3feb4d3
1 parent cbd8f08
commit 3feb4d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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);
         }