refine case

airborne12 · Nov 28, 2024 · ebae1c1 · ebae1c1
1 parent 9d2ba0c
commit ebae1c1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/be/src/olap/rowset/segment_v2/bloom_filter_index_reader.cpp b/be/src/olap/rowset/segment_v2/bloom_filter_index_reader.cpp
@@ -70,6 +70,7 @@ Status BloomFilterIndexIterator::read_bloom_filter(rowid_t ordinal,
     auto column = data_type->create_column();
 
     RETURN_IF_ERROR(_bloom_filter_iter.seek_to_ordinal(ordinal));
+    DCHECK(current_bloom_filter_index() == ordinal);
     size_t num_read = num_to_read;
     RETURN_IF_ERROR(_bloom_filter_iter.next_batch(&num_read, column));
     DCHECK(num_to_read == num_read);

diff --git a/be/test/olap/rowset/segment_v2/bloom_filter_index_reader_writer_test.cpp b/be/test/olap/rowset/segment_v2/bloom_filter_index_reader_writer_test.cpp
@@ -144,7 +144,7 @@ Status test_bloom_filter_index_reader_writer_template(
         BloomFilterIndexReader* reader = nullptr;
         std::unique_ptr<BloomFilterIndexIterator> iter;
         get_bloom_filter_reader_iter(file_name, meta, &reader, &iter);
-
+        EXPECT_EQ(reader->algorithm(), BloomFilterAlgorithmPB::BLOCK_BLOOM_FILTER);
         // page 0
         std::unique_ptr<BloomFilter> bf;
         RETURN_IF_ERROR(iter->read_bloom_filter(0, &bf));
@@ -604,6 +604,7 @@ Status read_and_test_ngram_bloom_filter_index_file(const std::string& file_name,
     BloomFilterIndexReader* reader = nullptr;
     std::unique_ptr<BloomFilterIndexIterator> iter;
     get_bloom_filter_reader_iter(file_name, meta, &reader, &iter);
+    EXPECT_EQ(reader->algorithm(), BloomFilterAlgorithmPB::NGRAM_BLOOM_FILTER);
 
     NgramTokenExtractor extractor(gram_size);
     uint16_t gram_bf_size = bf_size;