hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Add connect by child output exprs check

Browse Source
This commit is contained in:
obdev
2023-08-18 07:44:17 +00:00
committed by ob-robot
parent e842fa11c7
commit a14b34941e
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/sql/code_generator/ob_static_engine_cg.cpp
View File

@ -4100,6 +4100,9 @@ int ObStaticEngineCG::generate_pump_exprs(ObLogJoin &op, ObNLConnectBySpecBase &
if (OB_ISNULL(left_op) || OB_ISNULL(right_op)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected status: child is null", K(ret));
} else if (OB_UNLIKELY(left_output.count() != right_output.count())) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected status: left and right output size not same", K(ret));
} else if (OB_FAIL(generate_pseudo_column_expr(op, spec))) {
LOG_WARN("failed to generate pseudo column", K(ret));
} else if (OB_FAIL(spec.connect_by_prior_exprs_.init(left_output.count()))) {
@ -4131,7 +4134,7 @@ int ObStaticEngineCG::generate_pump_exprs(ObLogJoin &op, ObNLConnectBySpecBase &
} else if (OB_FAIL(spec.left_prior_exprs_.push_back(left_expr))) {
LOG_WARN("failed to push back left expr", K(ret));
} else if (OB_FAIL(spec.right_prior_exprs_.push_back(right_expr))) {
LOG_WARN("failed to push back left expr", K(ret));
LOG_WARN("failed to push back right expr", K(ret));
}
}
if (OB_SUCC(ret)) {