From 899927cf6e517690622cb6cab40d15f19bd229cb Mon Sep 17 00:00:00 2001 From: Jan Tuomi Date: Fri, 10 Jan 2025 22:25:01 +0200 Subject: Fix delete compact bug --- log_db/src/lib.rs | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) (limited to 'log_db/src') diff --git a/log_db/src/lib.rs b/log_db/src/lib.rs index 918f5e1..928da8d 100644 --- a/log_db/src/lib.rs +++ b/log_db/src/lib.rs @@ -813,7 +813,7 @@ impl DB { let active_num = parse_segment_number(&active_target)?; debug!("Reading segment data into a BTreeMap"); - let mut pk_to_item_map = BTreeMap::new(); + let mut pk_to_item_map: BTreeMap<&IndexableValue, &Record> = BTreeMap::new(); let forward_read_items: Vec<(IndexableValue, Record)> = ForwardLogReader::new( self.active_metadata_file.try_clone()?, self.active_data_file.try_clone()?, @@ -832,12 +832,7 @@ impl DB { self.active_data_file.unlock()?; for (pk, record) in forward_read_items.iter() { - // If the record is a tombstone, remove the PK from the map - if record.tombstone { - pk_to_item_map.remove(pk); - } else { - pk_to_item_map.insert(pk, record); - } + pk_to_item_map.insert(pk, record); } debug!( -- cgit v1.3