fix

risingwavelabs · Feb 5, 2025 · 6b98abe · 6b98abe
1 parent 163486a
commit 6b98abe
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/meta/src/barrier/progress.rs b/src/meta/src/barrier/progress.rs
@@ -535,7 +535,8 @@ impl CreateMviewProgressTracker {
             for (table_id, actors) in upstream_root_actors {
                 assert!(!actors.is_empty());
                 let dispatch_count: usize = dispatchers
-                    .iter()
+                    .values()
+                    .flatten()
                     .filter(|(upstream_actor_id, _)| actors.contains(upstream_actor_id))
                     .map(|(_, v)| v.len())
                     .sum();