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 59d3ad708db branch-4.0: [fix](predicate) Fix coredump if exception
occurs #60162 (#60184)
59d3ad708db is described below
commit 59d3ad708db097c294bcb211c92307f091073d25
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Jan 23 17:53:07 2026 +0800
branch-4.0: [fix](predicate) Fix coredump if exception occurs #60162
(#60184)
Cherry-picked from #60162
Co-authored-by: Gabriel <[email protected]>
---
be/src/pipeline/exec/scan_operator.cpp | 18 ++++++++++++++++++
1 file changed, 18 insertions(+)
diff --git a/be/src/pipeline/exec/scan_operator.cpp
b/be/src/pipeline/exec/scan_operator.cpp
index 536896a3304..f5b61fef055 100644
--- a/be/src/pipeline/exec/scan_operator.cpp
+++ b/be/src/pipeline/exec/scan_operator.cpp
@@ -440,6 +440,9 @@ Status ScanLocalState<Derived>::_normalize_bloom_filter(
if (pred) {
DCHECK(*pdt != PushDownType::UNACCEPTABLE) << root->debug_string();
predicates.emplace_back(pred);
+ } else {
+ // If exception occurs during processing, do not push down
+ *pdt = PushDownType::UNACCEPTABLE;
}
};
DCHECK(TExprNodeType::BLOOM_PRED == root->node_type());
@@ -466,6 +469,9 @@ Status ScanLocalState<Derived>::_normalize_topn_filter(
if (pred) {
DCHECK(*pdt != PushDownType::UNACCEPTABLE) << root->debug_string();
predicates.emplace_back(pred);
+ } else {
+ // If exception occurs during processing, do not push down
+ *pdt = PushDownType::UNACCEPTABLE;
}
};
DCHECK(root->is_topn_filter());
@@ -490,6 +496,9 @@ Status ScanLocalState<Derived>::_normalize_bitmap_filter(
if (pred) {
DCHECK(*pdt != PushDownType::UNACCEPTABLE) << root->debug_string();
predicates.emplace_back(pred);
+ } else {
+ // If exception occurs during processing, do not push down
+ *pdt = PushDownType::UNACCEPTABLE;
}
};
DCHECK(TExprNodeType::BITMAP_PRED == root->node_type());
@@ -638,6 +647,9 @@ Status ScanLocalState<Derived>::_normalize_in_predicate(
if (pred) {
DCHECK(*pdt != PushDownType::UNACCEPTABLE) << root->debug_string();
predicates.emplace_back(pred);
+ } else {
+ // If exception occurs during processing, do not push down
+ *pdt = PushDownType::UNACCEPTABLE;
}
};
@@ -736,6 +748,9 @@ Status ScanLocalState<Derived>::_normalize_binary_predicate(
if (pred) {
DCHECK(*pdt != PushDownType::UNACCEPTABLE) << root->debug_string();
predicates.emplace_back(pred);
+ } else {
+ // If exception occurs during processing, do not push down
+ *pdt = PushDownType::UNACCEPTABLE;
}
};
@@ -913,6 +928,9 @@ Status
ScanLocalState<Derived>::_normalize_is_null_predicate(
if (pred) {
DCHECK(*pdt != PushDownType::UNACCEPTABLE) << root->debug_string();
predicates.emplace_back(pred);
+ } else {
+ // If exception occurs during processing, do not push down
+ *pdt = PushDownType::UNACCEPTABLE;
}
};
DCHECK(!root->is_rf_wrapper()) << root->debug_string();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
