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 15b14ef49b8 [fix](inverted index) fix error handling in fast_execute
(#40086)
15b14ef49b8 is described below
commit 15b14ef49b8c9bd7f8495bbedd9a152b960d4ba1
Author: zzzxl <[email protected]>
AuthorDate: Thu Aug 29 14:45:25 2024 +0800
[fix](inverted index) fix error handling in fast_execute (#40086)
https://github.com/apache/doris/pull/40024
---
be/src/vec/exprs/vexpr.cpp | 13 +++++++++++++
be/src/vec/exprs/vexpr.h | 1 +
2 files changed, 14 insertions(+)
diff --git a/be/src/vec/exprs/vexpr.cpp b/be/src/vec/exprs/vexpr.cpp
index c615c91dc75..b66c8aa80a7 100644
--- a/be/src/vec/exprs/vexpr.cpp
+++ b/be/src/vec/exprs/vexpr.cpp
@@ -210,6 +210,7 @@ Status VExpr::prepare(RuntimeState* state, const
RowDescriptor& row_desc, VExprC
RETURN_IF_ERROR(i->prepare(state, row_desc, context));
}
--context->_depth_num;
+ _enable_inverted_index_query =
state->query_options().enable_inverted_index_query;
return Status::OK();
}
@@ -603,6 +604,10 @@ Status VExpr::get_result_from_const(vectorized::Block*
block, const std::string&
bool VExpr::fast_execute(Block& block, const ColumnNumbers& arguments, size_t
result,
size_t input_rows_count, const std::string&
function_name) {
+ if (!_enable_inverted_index_query) {
+ return false;
+ }
+
std::string result_column_name = gen_predicate_result_sign(block,
arguments, function_name);
if (!block.has(result_column_name)) {
DBUG_EXECUTE_IF("segment_iterator.fast_execute", {
@@ -651,11 +656,19 @@ std::string VExpr::gen_predicate_result_sign(Block&
block, const ColumnNumbers&
std::set<std::string> values;
for (size_t i = 1; i < arguments.size(); i++) {
const auto& entry = block.get_by_position(arguments[i]);
+ if (!is_column_const(*entry.column)) {
+ return pred_result_sign;
+ }
values.insert(entry.type->to_string(*entry.column, 0));
}
pred_result_sign += boost::join(values, ",");
+ } else if (function_name == "collection_in" || function_name ==
"collection_not_in") {
+ return pred_result_sign;
} else {
const auto& entry = block.get_by_position(arguments[1]);
+ if (!is_column_const(*entry.column)) {
+ return pred_result_sign;
+ }
pred_result_sign += entry.type->to_string(*entry.column, 0);
}
}
diff --git a/be/src/vec/exprs/vexpr.h b/be/src/vec/exprs/vexpr.h
index 0f611cb0920..777d485156a 100644
--- a/be/src/vec/exprs/vexpr.h
+++ b/be/src/vec/exprs/vexpr.h
@@ -306,6 +306,7 @@ protected:
// ensuring uniqueness during index traversal
uint32_t _index_unique_id = 0;
bool _can_fast_execute = false;
+ bool _enable_inverted_index_query = true;
};
} // namespace vectorized
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
