This is an automated email from the ASF dual-hosted git repository.
lihaopeng pushed a commit to branch tpcds
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/tpcds by this push:
new e782e9e3973 fix in_or_bloom filter merge error in broadcast join
remote target (#30471)
e782e9e3973 is described below
commit e782e9e3973f007dccf9b4ac67dec5d7520223eb
Author: HappenLee <[email protected]>
AuthorDate: Sun Jan 28 01:39:56 2024 +0800
fix in_or_bloom filter merge error in broadcast join remote target (#30471)
---
be/src/exprs/runtime_filter.cpp | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/be/src/exprs/runtime_filter.cpp b/be/src/exprs/runtime_filter.cpp
index 847b5a1746e..7ae9524b217 100644
--- a/be/src/exprs/runtime_filter.cpp
+++ b/be/src/exprs/runtime_filter.cpp
@@ -540,7 +540,7 @@ public:
} else {
VLOG_DEBUG << " change runtime filter to bloom filter(id="
<< _filter_id
<< ") because: already exist a bloom filter";
- change_to_bloom_filter(true);
+ change_to_bloom_filter();
RETURN_IF_ERROR(_context.bloom_filter_func->merge(
wrapper->_context.bloom_filter_func.get()));
}
@@ -1319,7 +1319,6 @@ Status
IRuntimeFilter::_create_wrapper(RuntimeFilterParamsContext* state, const
}
wrapper->reset(new RuntimePredicateWrapper(state, pool, column_type,
get_type(filter_type),
param->request->filter_id()));
-
switch (filter_type) {
case PFilterType::IN_FILTER: {
DCHECK(param->request->has_in_filter());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
