Skip to content

Commit 27a02c0

Browse files
committed
update
1 parent dadc8ce commit 27a02c0

File tree

1 file changed

+1
-3
lines changed
  • src/query/service/src/pipelines/processors/transforms/hash_join/runtime_filter

1 file changed

+1
-3
lines changed

src/query/service/src/pipelines/processors/transforms/hash_join/runtime_filter/convert.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -273,9 +273,7 @@ async fn build_bloom_filter(
273273
.map(|chunk| {
274274
databend_common_base::runtime::spawn(async move {
275275
let mut filter = BloomFilter::with_false_pos(0.01).expected_items(total_items);
276-
for hash in chunk {
277-
filter.insert_hash(hash);
278-
}
276+
filter.extend(chunk);
279277
Ok::<BloomFilter, ErrorCode>(filter)
280278
})
281279
})

0 commit comments

Comments
 (0)