fix source backfill

risingwavelabs · Jan 31, 2025 · 7bb1af8 · 7bb1af8
1 parent 1aff201
commit 7bb1af8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/meta/src/stream/source_manager/split_assignment.rs b/src/meta/src/stream/source_manager/split_assignment.rs
@@ -250,7 +250,7 @@ impl SourceManager {
 
         for (_source_id, fragments) in source_backfill_fragments {
             for (fragment_id, upstream_source_fragment_id) in fragments {
-                let fragment_dispatchers = dispatchers.get(&fragment_id);
+                let fragment_dispatchers = dispatchers.get(&upstream_source_fragment_id);
                 let upstream_actors = core
                     .metadata_manager
                     .get_running_actors_of_fragment(upstream_source_fragment_id)