Skip to content

Commit a2a3cb3

Browse files
committed
remove assertion
1 parent be639ef commit a2a3cb3

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

src/meta/src/stream/source_manager.rs

Lines changed: 7 additions & 6 deletions
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)