remove assertion

risingwavelabs · Jan 3, 2025 · a2a3cb3 · a2a3cb3
1 parent be639ef
commit a2a3cb3
Showing 1 changed file with 7 additions and 6 deletions.
diff --git 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
+                // );
             }
         }