remove assertion

risingwavelabs · Jan 2, 2025 · 478f935 · 478f935
1 parent 5447332
commit 478f935
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/src/meta/src/stream/source_manager.rs b/src/meta/src/stream/source_manager.rs
@@ -521,11 +521,12 @@ impl SourceManagerCore {
             }
             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
-                );
+                // 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
+                // );
             }
         }