From 8619b1119cf07f34c6a0ed1d0792773c439f1d98 Mon Sep 17 00:00:00 2001 From: Wallace Date: Wed, 22 Feb 2023 18:21:53 +0800 Subject: [PATCH] fix(storage): fix skip delete range in uncommitted files (#8009) Approved-By: Li0k --- src/storage/src/hummock/store/version.rs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/src/storage/src/hummock/store/version.rs b/src/storage/src/hummock/store/version.rs index 5a71706d0a46..fde7ab4aad4e 100644 --- a/src/storage/src/hummock/store/version.rs +++ b/src/storage/src/hummock/store/version.rs @@ -555,11 +555,6 @@ impl HummockVersionReader { .sstable(sstable_info, &mut local_stats) .in_span(Span::enter_with_local_parent("get_sstable")) .await?; - if let Some(prefix_hash) = bloom_filter_prefix_hash.as_ref() { - if !hit_sstable_bloom_filter(table_holder.value(), *prefix_hash, &mut local_stats) { - continue; - } - } if !table_holder.value().meta.range_tombstone_list.is_empty() && !read_options.ignore_range_tombstone @@ -567,6 +562,12 @@ impl HummockVersionReader { delete_range_iter .add_sst_iter(SstableDeleteRangeIterator::new(table_holder.clone())); } + if let Some(prefix_hash) = bloom_filter_prefix_hash.as_ref() { + if !hit_sstable_bloom_filter(table_holder.value(), *prefix_hash, &mut local_stats) { + continue; + } + } + staging_sst_iter_count += 1; staging_iters.push(HummockIteratorUnion::Second(SstableIterator::new( table_holder,