Skip to content

Commit ff48e40

Browse files
committed
remove assertion
1 parent 5447332 commit ff48e40

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

src/meta/src/stream/source_manager.rs

+7-6
Original file line numberDiff line numberDiff line change
@@ -520,12 +520,13 @@ impl SourceManagerCore {
520520
handle.handle.abort();
521521
}
522522
self.source_fragments.remove(&source_id);
523-
if let Some(fragments) = self.backfill_fragments.remove(&source_id) {
524-
debug_assert!(
525-
fragments.is_empty(),
526-
"when dropping source, there should be no backfill fragments, got: {:?}",
527-
fragments
528-
);
523+
if let Some(_fragments) = self.backfill_fragments.remove(&source_id) {
524+
// TODO: enable this assertion after we implemented cleanup for backfill fragments
525+
// debug_assert!(
526+
// fragments.is_empty(),
527+
// "when dropping source, there should be no backfill fragments, got: {:?}",
528+
// fragments
529+
// );
529530
}
530531
}
531532

0 commit comments

Comments
 (0)