Skip to content

Commit

Permalink
fix conflict
Browse files Browse the repository at this point in the history
  • Loading branch information
xxchan committed Oct 21, 2024
1 parent 80ff0b1 commit 8b4653e
Showing 1 changed file with 8 additions and 3 deletions.
11 changes: 8 additions & 3 deletions src/stream/src/task/barrier_manager/progress.rs
Original file line number Diff line number Diff line change
@@ -219,15 +219,20 @@ impl CreateMviewProgressReporter {
current_consumed_rows: ConsumedRows,
) {
match self.state {
Some(BackfillState::ConsumingUpstream(last_epoch, _last_consumed_rows)) => {
Some(BackfillState::ConsumingUpstreamTable(last_epoch, _last_consumed_rows)) => {
debug_assert_eq!(last_epoch, 0);
}
Some(BackfillState::Done(_)) => unreachable!(),
Some(state) => {
panic!(
"should not update consuming progress at invalid state: {:?}",
state
)
}
None => {}
};
self.update_inner(
epoch,
BackfillState::ConsumingUpstream(0, current_consumed_rows),
BackfillState::ConsumingUpstreamTable(0, current_consumed_rows),
);
}

0 comments on commit 8b4653e

Please sign in to comment.