This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a commit to branch test_0702
in repository https://gitbox.apache.org/repos/asf/doris.git
commit f0297cd459856f6a11bfb8456cd5719a98207d63
Author: BiteTheDDDDt <pxl...@qq.com>
AuthorDate: Tue Jul 2 19:45:42 2024 +0800
update
---
be/src/exprs/runtime_filter_slots.h | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/be/src/exprs/runtime_filter_slots.h
b/be/src/exprs/runtime_filter_slots.h
index b5b04a1ebac..ac85a02bed4 100644
--- a/be/src/exprs/runtime_filter_slots.h
+++ b/be/src/exprs/runtime_filter_slots.h
@@ -71,6 +71,9 @@ public:
// process ignore duplicate IN_FILTER
std::unordered_set<int> has_in_filter;
for (auto* filter : _runtime_filters) {
+ if (filter->get_ignored()) {
+ continue;
+ }
if (filter->get_real_type() != RuntimeFilterType::IN_FILTER) {
continue;
}
@@ -83,6 +86,9 @@ public:
// process ignore filter when it has IN_FILTER on same expr, and init
bloom filter size
for (auto* filter : _runtime_filters) {
+ if (filter->get_ignored()) {
+ continue;
+ }
if (filter->get_real_type() == RuntimeFilterType::IN_FILTER ||
!has_in_filter.contains(filter->expr_order())) {
continue;
@@ -95,6 +101,9 @@ public:
Status init_filters(RuntimeState* state, uint64_t local_hash_table_size) {
// process IN_OR_BLOOM_FILTER's real type
for (auto* filter : _runtime_filters) {
+ if (filter->get_ignored()) {
+ continue;
+ }
if (filter->type() == RuntimeFilterType::IN_OR_BLOOM_FILTER &&
get_real_size(filter, local_hash_table_size) >
state->runtime_filter_max_in_num()) {
RETURN_IF_ERROR(filter->change_to_bloom_filter());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
