This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 1e690ea6aa [fix](bitmapfilter) Set bitmap filter waiting time to the
query timeout. (#14623)
1e690ea6aa is described below
commit 1e690ea6aae34b7786f7c391f0d46a74876e5fbc
Author: luozenglin <[email protected]>
AuthorDate: Mon Nov 28 18:57:27 2022 +0800
[fix](bitmapfilter) Set bitmap filter waiting time to the query timeout.
(#14623)
bitmap filter is precise filter and only filter once, so it must be applied.
---
be/src/exprs/runtime_filter.cpp | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/be/src/exprs/runtime_filter.cpp b/be/src/exprs/runtime_filter.cpp
index 60e7bbc1ca..39760c7c3d 100644
--- a/be/src/exprs/runtime_filter.cpp
+++ b/be/src/exprs/runtime_filter.cpp
@@ -1234,7 +1234,10 @@ Status
IRuntimeFilter::get_prepared_vexprs(std::vector<doris::vectorized::VExpr*
bool IRuntimeFilter::await() {
DCHECK(is_consumer());
SCOPED_TIMER(_await_time_cost);
- int64_t wait_times_ms = _state->runtime_filter_wait_time_ms();
+ // bitmap filter is precise filter and only filter once, so it must be
applied.
+ int64_t wait_times_ms = _wrapper->get_real_type() ==
RuntimeFilterType::BITMAP_FILTER
+ ? _state->query_options().query_timeout
+ : _state->runtime_filter_wait_time_ms();
std::unique_lock<std::mutex> lock(_inner_mutex);
if (!_is_ready) {
int64_t ms_since_registration = MonotonicMillis() - registration_time_;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
