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

[CP] fix nlj not clear eval flag bug

Browse Source
This commit is contained in:
obdev
2024-01-23 02:17:05 +00:00
committed by ob-robot
parent 60708358b8
commit ea49c78176
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -398,6 +398,7 @@ int ObNestedLoopJoinOp::join_end_func_end()
int ObNestedLoopJoinOp::read_left_operate() int ObNestedLoopJoinOp::read_left_operate()
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
clear_evaluated_flag();
if (MY_SPEC.group_rescan_ || MY_SPEC.enable_px_batch_rescan_) { if (MY_SPEC.group_rescan_ || MY_SPEC.enable_px_batch_rescan_) {
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));
@ -633,10 +634,9 @@ int ObNestedLoopJoinOp::read_left_func_end()
int ObNestedLoopJoinOp::read_right_operate() int ObNestedLoopJoinOp::read_right_operate()
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
clear_evaluated_flag();
if (OB_FAIL(get_next_right_row()) && OB_ITER_END != ret) { if (OB_FAIL(get_next_right_row()) && OB_ITER_END != ret) {
LOG_WARN("failed to get next right row", K(ret)); LOG_WARN("failed to get next right row", K(ret));
} else {
clear_evaluated_flag();
} }
return ret; return ret;