This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new a623bfe7543 [opt](pipeline) Return InternalError to FE instead of
doing a useless DCHECK in ExecNode #27035 (#27057)
a623bfe7543 is described below
commit a623bfe7543490d2776eb7579c2707b07bfba607
Author: zhiqiang <[email protected]>
AuthorDate: Wed Nov 15 20:03:26 2023 -0600
[opt](pipeline) Return InternalError to FE instead of doing a useless
DCHECK in ExecNode #27035 (#27057)
Effect: Client will see error message like below when BE meeting plan
logical error.
RROR 1105 (HY000): errCode = 2, detailMessage = ([xxx]())[CANCELLED]Logical
error during processing VNewOlapScanNode(dr_case_tag), output of projections 2
mismatches with exec node output 3
---
be/src/exec/exec_node.cpp | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git a/be/src/exec/exec_node.cpp b/be/src/exec/exec_node.cpp
index dc30bf163a5..2ee3f1ba693 100644
--- a/be/src/exec/exec_node.cpp
+++ b/be/src/exec/exec_node.cpp
@@ -558,7 +558,14 @@ Status ExecNode::do_projections(vectorized::Block*
origin_block, vectorized::Blo
if (rows != 0) {
auto& mutable_columns = mutable_block.mutable_columns();
- DCHECK(mutable_columns.size() == _projections.size());
+
+ if (mutable_columns.size() != _projections.size()) {
+ return Status::InternalError(
+ "Logical error during processing {}, output of projections
{} mismatches with "
+ "exec node output {}",
+ this->get_name(), _projections.size(),
mutable_columns.size());
+ }
+
for (int i = 0; i < mutable_columns.size(); ++i) {
auto result_column_id = -1;
RETURN_IF_ERROR(_projections[i]->execute(origin_block,
&result_column_id));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
