Skip to content

Commit beaea63

Browse files
authored
Fix incorrect delete version on update (#7303)
1 parent bf8e86f commit beaea63

1 file changed

Lines changed: 8 additions & 8 deletions

File tree

  • lib/shard/src/segment_holder

lib/shard/src/segment_holder/mod.rs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -568,12 +568,13 @@ impl SegmentHolder {
568568
let mut write_segment = segment_arc.write();
569569

570570
for point_id in points {
571-
let version = write_segment.point_version(point_id).unwrap_or_default();
572-
write_segment.delete_point(
573-
version,
574-
point_id,
575-
&HardwareCounterCell::disposable(), // Internal operation: no need to measure.
576-
)?;
571+
if let Some(version) = write_segment.point_version(point_id) {
572+
write_segment.delete_point(
573+
version,
574+
point_id,
575+
&HardwareCounterCell::disposable(), // Internal operation: no need to measure.
576+
)?;
577+
}
577578
}
578579
}
579580

@@ -975,8 +976,7 @@ impl SegmentHolder {
975976
log::trace!("Applying function on all proxied shard segments");
976977
let mut result = Ok(());
977978
let mut unproxied_segment_ids = Vec::with_capacity(proxies.len());
978-
// Reverse to unproxify first non-appendable segments
979-
proxies.reverse();
979+
980980
for (segment_id, proxy_segment) in &proxies {
981981
// Get segment to snapshot
982982
let op_result = match proxy_segment {

0 commit comments

Comments
 (0)