This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new dca74d895f8 branch-4.0:[fix](column predicate)fix topn&bloom&bitmap
filter convert to column predicate error. (#60262) (#60268)
dca74d895f8 is described below
commit dca74d895f8f6f4c41bd9876e86bb2f7cfe6d0c2
Author: daidai <[email protected]>
AuthorDate: Tue Jan 27 21:13:05 2026 +0800
branch-4.0:[fix](column predicate)fix topn&bloom&bitmap filter convert to
column predicate error. (#60262) (#60268)
### What problem does this PR solve?
Problem Summary:
bp #60262
---
be/src/pipeline/exec/file_scan_operator.h | 4 ++--
be/src/runtime/runtime_predicate.cpp | 3 +++
2 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/be/src/pipeline/exec/file_scan_operator.h
b/be/src/pipeline/exec/file_scan_operator.h
index 38e34e0a4bb..9c99df14874 100644
--- a/be/src/pipeline/exec/file_scan_operator.h
+++ b/be/src/pipeline/exec/file_scan_operator.h
@@ -61,7 +61,7 @@ public:
private:
friend class vectorized::FileScanner;
PushDownType _should_push_down_bloom_filter() const override {
- return PushDownType::PARTIAL_ACCEPTABLE;
+ return PushDownType::UNACCEPTABLE;
}
PushDownType _should_push_down_topn_filter() const override {
return PushDownType::PARTIAL_ACCEPTABLE;
@@ -73,7 +73,7 @@ private:
}
PushDownType _should_push_down_bitmap_filter() const override {
- return PushDownType::PARTIAL_ACCEPTABLE;
+ return PushDownType::UNACCEPTABLE;
}
PushDownType _should_push_down_is_null_predicate(
vectorized::VectorizedFnCall* fn_call) const override {
diff --git a/be/src/runtime/runtime_predicate.cpp
b/be/src/runtime/runtime_predicate.cpp
index f034a764399..5b100215653 100644
--- a/be/src/runtime/runtime_predicate.cpp
+++ b/be/src/runtime/runtime_predicate.cpp
@@ -214,6 +214,9 @@ Status RuntimePredicate::update(const Field& value) {
}
for (auto p : _contexts) {
auto ctx = p.second;
+ if (ctx.predicate == nullptr) {
+ continue;
+ }
auto str_ref = _get_string_ref(_orderby_extrem, _type);
std::shared_ptr<ColumnPredicate> pred =
_pred_constructor(ctx.predicate->column_id(), ctx.col_name,
ctx.col_data_type,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
