From 9812e7b4e879e8684fcea3cce909065c1e7afbd5 Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Fri, 22 Sep 2023 22:20:11 +0800 Subject: [PATCH] fix --- src/meta/src/barrier/progress.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/meta/src/barrier/progress.rs b/src/meta/src/barrier/progress.rs index 3ecded91a46cb..db713997a2c6d 100644 --- a/src/meta/src/barrier/progress.rs +++ b/src/meta/src/barrier/progress.rs @@ -409,7 +409,7 @@ impl CreateMviewProgressTracker { version_stats: &HummockVersionStats, ) -> Option { 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, @@ -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() {