Skip to content

Commit

Permalink
cleanup and debug
Browse files Browse the repository at this point in the history
- The reason why progress cant finish is because other actors have finished already, but they need to re-report to create mview progress tracker on recovery, otherwise it wont know
  • Loading branch information
kwannoel committed Sep 22, 2023
1 parent 3efb691 commit d1849cb
Showing 1 changed file with 2 additions and 9 deletions.
11 changes: 2 additions & 9 deletions src/meta/src/barrier/progress.rs
Original file line number Diff line number Diff line change
Expand Up @@ -114,6 +114,8 @@ impl Progress {

/// Returns whether all chains are done.
fn is_done(&self) -> bool {
println!("done_count: {:#?}", self.done_count);
println!("states_len: {:#?}", self.states.len());
self.done_count == self.states.len()
}

Expand Down Expand Up @@ -432,20 +434,11 @@ impl CreateMviewProgressTracker {
Entry::Occupied(mut o) => {
let progress = &mut o.get_mut().0;

println!("upstream mv count: {:#?}", &progress.upstream_mv_count);
let upstream_total_key_count: u64 = progress
.upstream_mv_count
.iter()
.map(|(upstream_mv, count)| {
assert_ne!(*count, 0);
println!("Upstream mv count: {}", count);
println!(
"table count: {:#?}",
version_stats
.table_stats
.get(&upstream_mv.table_id)
.map(|stat| stat.total_key_count as u64)
);
*count as u64
* version_stats
.table_stats
Expand Down

0 comments on commit d1849cb

Please sign in to comment.