fix(meta): handle case where progress is done (#12631)

risingwavelabs · Oct 5, 2023 · 8195963 · 8195963
1 parent e365f2f
commit 8195963
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/meta/src/barrier/progress.rs b/src/meta/src/barrier/progress.rs
@@ -93,9 +93,7 @@ impl Progress {
         match self.states.remove(&actor).unwrap() {
             ChainState::Init => {}
             ChainState::ConsumingUpstream(_, old_consumed_rows) => {
-                if !matches!(new_state, ChainState::Done(_)) {
-                    self.consumed_rows -= old_consumed_rows;
-                }
+                self.consumed_rows -= old_consumed_rows;
             }
             ChainState::Done(_) => panic!("should not report done multiple times"),
         };