diff --git a/src/stream/src/executor/backfill/snapshot_backfill/vnode_stream.rs b/src/stream/src/executor/backfill/snapshot_backfill/vnode_stream.rs index 25f7fe9dddbe..71fde5771e3a 100644 --- a/src/stream/src/executor/backfill/snapshot_backfill/vnode_stream.rs +++ b/src/stream/src/executor/backfill/snapshot_backfill/vnode_stream.rs @@ -91,7 +91,6 @@ impl VnodeStream { } } - #[expect(dead_code)] pub(super) fn consume_builder(&mut self) -> Option { self.data_chunk_builder.consume_all().map(|chunk| { let ops = replace( @@ -102,7 +101,6 @@ impl VnodeStream { }) } - #[expect(dead_code)] pub(super) async fn for_vnode_pk_progress( &mut self, pk_indices: &[usize],