Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
kwannoel committed Sep 22, 2023
1 parent d1849cb commit 9812e7b
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions src/meta/src/barrier/progress.rs
Original file line number Diff line number Diff line change
Expand Up @@ -409,7 +409,7 @@ impl CreateMviewProgressTracker {
version_stats: &HummockVersionStats,
) -> Option<TrackingCommand> {
let actor = progress.chain_actor_id;
let Some(epoch) = self.actor_map.get(&actor).copied() else {
let Some(table_id) = self.actor_map.get(&actor).copied() else {
// On restart, backfill will ALWAYS notify CreateMviewProgressTracker,
// even if backfill is finished on recovery.
// This is because we don't know if only this actor is finished,
Expand Down Expand Up @@ -450,7 +450,10 @@ impl CreateMviewProgressTracker {
progress.update(actor, new_state, upstream_total_key_count);

if progress.is_done() {
tracing::debug!("all actors done for creating mview with table_id {}!", table_id);
tracing::debug!(
"all actors done for creating mview with table_id {}!",
table_id
);

// Clean-up the mapping from actors to DDL epoch.
for actor in o.get().0.actors() {
Expand Down

0 comments on commit 9812e7b

Please sign in to comment.