diff --git a/src/mito2/src/cache/write_cache.rs b/src/mito2/src/cache/write_cache.rs index 455e7c9e3057..23304a8b1ea9 100644 --- a/src/mito2/src/cache/write_cache.rs +++ b/src/mito2/src/cache/write_cache.rs @@ -81,12 +81,6 @@ pub(crate) struct UploadPart { pub(crate) file_metas: Vec, /// Target storage of SSTs. storage: Option, - /// Sender to send notify. - request_sender: Option>, - /// The last entry id has been flushed. - flushed_entry_id: Option, - /// The last sequence has been flushed. - flushed_sequence: Option, } /// Writer to build a upload part. @@ -101,12 +95,6 @@ pub(crate) struct UploadPartWriter { file_metas: Vec, /// Target storage of SSTs. storage: Option, - /// Sender to send notify. - request_sender: Option>, - /// The last entry id has been flushed. - flushed_entry_id: Option, - /// The last sequence has been flushed. - flushed_sequence: Option, } impl UploadPartWriter { @@ -118,9 +106,6 @@ impl UploadPartWriter { region_dir: String::new(), file_metas: Vec::new(), storage: None, - request_sender: None, - flushed_entry_id: None, - flushed_sequence: None, } } @@ -138,27 +123,6 @@ impl UploadPartWriter { self } - /// Sets request sender for the part. - #[must_use] - pub(crate) fn with_request_sender(mut self, sender: Option>) -> Self { - self.request_sender = sender; - self - } - - /// Sets flushed entry id. - #[must_use] - pub(crate) fn with_flushed_entry_id(mut self, entry_id: Option) -> Self { - self.flushed_entry_id = entry_id; - self - } - - /// Sets flushed sequence. - #[must_use] - pub(crate) fn with_flushed_sequence(mut self, sequence: Option) -> Self { - self.flushed_sequence = sequence; - self - } - /// Reserve capacity for `additional` files. pub(crate) fn reserve_capacity(&mut self, additional: usize) { self.file_metas.reserve(additional); @@ -192,9 +156,6 @@ impl UploadPartWriter { region_dir: self.region_dir, file_metas: self.file_metas, storage: self.storage, - request_sender: self.request_sender, - flushed_entry_id: self.flushed_entry_id, - flushed_sequence: self.flushed_sequence, } } } diff --git a/src/mito2/src/compaction/twcs.rs b/src/mito2/src/compaction/twcs.rs index 7ada8bc69c6e..d8bf03cb500f 100644 --- a/src/mito2/src/compaction/twcs.rs +++ b/src/mito2/src/compaction/twcs.rs @@ -287,8 +287,7 @@ impl TwcsCompactionTask { let mut part_writer = self .sst_layer .upload_part_writer(self.metadata.clone(), &self.cache_manager) - .with_storage(self.storage.clone()) - .with_request_sender(Some(self.request_sender.clone())); + .with_storage(self.storage.clone()); for output in self.outputs.drain(..) { compacted_inputs.extend(output.inputs.iter().map(FileHandle::meta)); diff --git a/src/mito2/src/flush.rs b/src/mito2/src/flush.rs index a36c6674bffd..ee3a0a6d8859 100644 --- a/src/mito2/src/flush.rs +++ b/src/mito2/src/flush.rs @@ -252,10 +252,7 @@ impl RegionFlushTask { let mut writer = self .access_layer .upload_part_writer(version.metadata.clone(), &self.cache_manager) - .with_storage(version.options.storage.clone()) - .with_request_sender(Some(self.request_sender.clone())) - .with_flushed_entry_id(Some(version_data.last_entry_id)) - .with_flushed_sequence(Some(version_data.committed_sequence)); + .with_storage(version.options.storage.clone()); let worker_request = match self .flush_memtables(&version_data.version, &mut writer)