This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.2-lts by this push:
new 4db9725940 [branch-1.2][improvement](limit) check exec node limit
against invalid value (#21463)
4db9725940 is described below
commit 4db9725940f29007dc020e43af64ff7dc14db771
Author: TengJianPing <[email protected]>
AuthorDate: Mon Jul 3 23:30:09 2023 +0800
[branch-1.2][improvement](limit) check exec node limit against invalid
value (#21463)
To improve BE robustness, set ExecNode::_limit to -1 if FE set it to an
invalid value.
---
be/src/exec/exec_node.cpp | 3 +++
1 file changed, 3 insertions(+)
diff --git a/be/src/exec/exec_node.cpp b/be/src/exec/exec_node.cpp
index d73888e0b8..5beced352e 100644
--- a/be/src/exec/exec_node.cpp
+++ b/be/src/exec/exec_node.cpp
@@ -152,6 +152,9 @@ ExecNode::ExecNode(ObjectPool* pool, const TPlanNode&
tnode, const DescriptorTbl
_memory_used_counter(nullptr),
_get_next_span(),
_is_closed(false) {
+ if (_limit < -1) {
+ _limit = -1;
+ }
if (tnode.__isset.output_tuple_id) {
_output_row_descriptor.reset(new RowDescriptor(descs,
{tnode.output_tuple_id}, {true}));
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
