From ff48e40d8bc277de61827315c3c4781e676e5cc3 Mon Sep 17 00:00:00 2001 From: xxchan Date: Thu, 2 Jan 2025 17:03:46 +0800 Subject: [PATCH] remove assertion --- src/meta/src/stream/source_manager.rs | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/src/meta/src/stream/source_manager.rs b/src/meta/src/stream/source_manager.rs index 1c80a46d0cec9..08682567b871d 100644 --- a/src/meta/src/stream/source_manager.rs +++ b/src/meta/src/stream/source_manager.rs @@ -520,12 +520,13 @@ impl SourceManagerCore { handle.handle.abort(); } self.source_fragments.remove(&source_id); - if let Some(fragments) = self.backfill_fragments.remove(&source_id) { - debug_assert!( - fragments.is_empty(), - "when dropping source, there should be no backfill fragments, got: {:?}", - fragments - ); + if let Some(_fragments) = self.backfill_fragments.remove(&source_id) { + // TODO: enable this assertion after we implemented cleanup for backfill fragments + // debug_assert!( + // fragments.is_empty(), + // "when dropping source, there should be no backfill fragments, got: {:?}", + // fragments + // ); } }