From 8114711949cab58e735fb945acbe0b2ea858966d Mon Sep 17 00:00:00 2001 From: William Wen Date: Fri, 31 Jan 2025 17:11:29 +0800 Subject: [PATCH] fix source backfill --- src/meta/src/stream/source_manager/split_assignment.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/meta/src/stream/source_manager/split_assignment.rs b/src/meta/src/stream/source_manager/split_assignment.rs index 8d23862afccbc..f69f2b3c08359 100644 --- 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)