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

[CP] fix subplan fiter exec param not reset caused core

Browse Source
This commit is contained in:
obdev
2022-11-09 02:38:07 +00:00
committed by wangzelin.wzl
parent 6608b24752
commit 0c704f0ff0
2 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/engine/join/ob_nested_loop_join_op.cpp
View File

@ -360,6 +360,7 @@ int ObNestedLoopJoinOp::read_left_operate()
if (OB_FAIL(group_read_left_operate()) && OB_ITER_END != ret) { if (OB_FAIL(group_read_left_operate()) && OB_ITER_END != ret) {
LOG_WARN("failed to read left group", K(ret)); LOG_WARN("failed to read left group", K(ret));
} }
} else if (FALSE_IT(set_param_null())) {
} else if (OB_FAIL(get_next_left_row()) && OB_ITER_END != ret) { } else if (OB_FAIL(get_next_left_row()) && OB_ITER_END != ret) {
LOG_WARN("failed to get next left row", K(ret)); LOG_WARN("failed to get next left row", K(ret));
} }
@ -530,6 +531,7 @@ int ObNestedLoopJoinOp::group_read_left_operate()
} }
} }
save_last_row_ = false; save_last_row_ = false;
set_param_null();
while (OB_SUCC(ret) && !is_full()) { while (OB_SUCC(ret) && !is_full()) {
// need clear evaluated flag, since prepare_rescan_params() will evaluate expression. // need clear evaluated flag, since prepare_rescan_params() will evaluate expression.
clear_evaluated_flag(); clear_evaluated_flag();

1
src/sql/engine/subquery/ob_subplan_filter_op.cpp
View File

@ -602,6 +602,7 @@ int ObSubPlanFilterOp::handle_next_row()
} }
} }
save_last_row_ = false; save_last_row_ = false;
set_param_null();
while (OB_SUCC(ret) && batch_count--) { while (OB_SUCC(ret) && batch_count--) {
clear_evaluated_flag(); clear_evaluated_flag();
set_param_null(); set_param_null();