This is an automated email from the ASF dual-hosted git repository.
panxiaolei 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 851d780c14d [Chore](check) add check for bf not inited and not ignored
(#44781)
851d780c14d is described below
commit 851d780c14d9e880547181b826ee57953869944d
Author: Pxl <x...@selectdb.com>
AuthorDate: Fri Nov 29 19:06:37 2024 +0800
[Chore](check) add check for bf not inited and not ignored (#44781)
add check for bf not inited and not ignored
---
be/src/exprs/bloom_filter_func.h | 2 ++
be/src/exprs/runtime_filter.cpp | 7 +++++++
2 files changed, 9 insertions(+)
diff --git a/be/src/exprs/bloom_filter_func.h b/be/src/exprs/bloom_filter_func.h
index 674a4295816..ff749420ad2 100644
--- a/be/src/exprs/bloom_filter_func.h
+++ b/be/src/exprs/bloom_filter_func.h
@@ -233,6 +233,8 @@ public:
uint16_t* offsets, int number,
bool is_parse_column) = 0;
+ bool inited() const { return _inited; }
+
private:
void _limit_length() {
if (_runtime_bloom_filter_min_size > 0) {
diff --git a/be/src/exprs/runtime_filter.cpp b/be/src/exprs/runtime_filter.cpp
index 19789fbd743..e26452c9ef6 100644
--- a/be/src/exprs/runtime_filter.cpp
+++ b/be/src/exprs/runtime_filter.cpp
@@ -1283,6 +1283,13 @@ PrimitiveType IRuntimeFilter::column_type() const {
void IRuntimeFilter::signal() {
DCHECK(is_consumer());
+
+ if (!_wrapper->is_ignored() && _wrapper->is_bloomfilter() &&
+ !_wrapper->get_bloomfilter()->inited()) {
+ throw Exception(ErrorCode::INTERNAL_ERROR, "bf not inited and not
ignored, rf: {}",
+ debug_string());
+ }
+
COUNTER_SET(_wait_timer, int64_t((MonotonicMillis() - registration_time_)
* NANOS_PER_MILLIS));
_rf_state_atomic.store(RuntimeFilterState::READY);
if (!_filter_timer.empty()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
