diff --git a/src/common/src/array/compact_chunk.rs b/src/common/src/array/compact_chunk.rs index 8634b5d3ca1a4..d64aa47c6769c 100644 --- a/src/common/src/array/compact_chunk.rs +++ b/src/common/src/array/compact_chunk.rs @@ -101,7 +101,6 @@ impl StreamChunkCompactor { /// Compact a chunk by modifying the ops and the visibility of a stream chunk. All UPDATE INSERT /// and UPDATE DELETE will be converted to INSERT and DELETE, and dropped according to /// certain rules (see `merge_insert` and `merge_delete` for more details). - pub fn into_compacted_chunks(self) -> impl Iterator { let (chunks, key_indices) = self.into_inner();