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
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 7355cfe8b64 [Chore](runtime-filter) remove wrong check and set disable
when SyncSizeClosure meet eof status (#49186)
7355cfe8b64 is described below
commit 7355cfe8b640dc4d391ba58ff78c28c0841caf5b
Author: Pxl <[email protected]>
AuthorDate: Tue Mar 18 18:16:51 2025 +0800
[Chore](runtime-filter) remove wrong check and set disable when
SyncSizeClosure meet eof status (#49186)
---
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 b4d911ec0cc..ecae073838c 100644
--- a/be/src/exprs/runtime_filter.cpp
+++ b/be/src/exprs/runtime_filter.cpp
@@ -391,7 +391,6 @@ public:
BloomFilterFuncBase* get_bloomfilter() const { return
_context->bloom_filter_func.get(); }
void insert_fixed_len(const vectorized::ColumnPtr& column, size_t start) {
- DCHECK(!is_ignored());
switch (_filter_type) {
case RuntimeFilterType::IN_FILTER: {
_context->hybrid_set->insert_fixed_len(column, start);
@@ -1114,7 +1113,7 @@ class SyncSizeClosure : public
AutoReleaseClosure<PSendFilterSizeRequest,
if (status.is<ErrorCode::END_OF_FILE>()) {
// rf merger backend may finished before rf's send_filter_size, we
just ignore filter in this case.
- ctx->ignored = true;
+ ctx->disabled = true;
} else {
ctx->err_msg = status.to_string();
Base::_process_if_meet_error_status(status);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
