This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 92a9e8265b4f1dc11a7e26caa116de7cb1cac896
Author: HappenLee <happen...@hotmail.com>
AuthorDate: Tue Jan 23 14:04:15 2024 +0800
[Imporve](RF) Support remote broadcast join build bf exactly (#30247)
---
be/src/exprs/runtime_filter.cpp | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/be/src/exprs/runtime_filter.cpp b/be/src/exprs/runtime_filter.cpp
index 3215b842afb..c509662a426 100644
--- a/be/src/exprs/runtime_filter.cpp
+++ b/be/src/exprs/runtime_filter.cpp
@@ -1196,9 +1196,9 @@ Status IRuntimeFilter::init_with_desc(const
TRuntimeFilterDesc* desc, const TQue
params.max_in_num = options->runtime_filter_max_in_num;
// We build runtime filter by exact distinct count iff three conditions
are met:
// 1. Only 1 join key
- // 2. Do not have remote target (e.g. do not need to merge)
+ // 2. Do not have remote target (e.g. do not need to merge), or broadcast
join
// 3. Bloom filter
- params.build_bf_exactly = build_bf_exactly && !_has_remote_target &&
+ params.build_bf_exactly = build_bf_exactly && (!_has_remote_target ||
_is_broadcast_join) &&
(_runtime_filter_type ==
RuntimeFilterType::BLOOM_FILTER ||
_runtime_filter_type ==
RuntimeFilterType::IN_OR_BLOOM_FILTER);
if (desc->__isset.bloom_filter_size_bytes) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
