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

[CP] fix program crashed when top_limit_cnt_ in operator select-into is set to zero

Browse Source
This commit is contained in:
obdev
2023-01-03 07:12:23 +00:00
committed by ob-robot
parent eddcded977
commit 4250b40aa2
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/sql/engine/basic/ob_select_into_op.cpp
View File

@ -142,7 +142,7 @@ int ObSelectIntoOp::inner_open()
int ObSelectIntoOp::inner_get_next_row() int ObSelectIntoOp::inner_get_next_row()
{ {
int ret = OB_SUCCESS; int ret = 0 == top_limit_cnt_ ? OB_ITER_END : OB_SUCCESS;
int64_t row_count = 0; int64_t row_count = 0;
const ObItemType into_type = MY_SPEC.into_type_; const ObItemType into_type = MY_SPEC.into_type_;
ObPhysicalPlanCtx *phy_plan_ctx = NULL; ObPhysicalPlanCtx *phy_plan_ctx = NULL;
@ -200,6 +200,11 @@ int ObSelectIntoOp::inner_get_next_batch(const int64_t max_row_cnt)
} }
bool stop_loop = false; bool stop_loop = false;
bool is_iter_end = false; bool is_iter_end = false;
if (0 == top_limit_cnt_) {
brs_.size_ = 0;
brs_.end_ = true;
stop_loop = true;
}
while (OB_SUCC(ret) && !stop_loop) { while (OB_SUCC(ret) && !stop_loop) {
clear_evaluated_flag(); clear_evaluated_flag();
int64_t rowkey_batch_size = min(batch_size, top_limit_cnt_ - row_count); int64_t rowkey_batch_size = min(batch_size, top_limit_cnt_ - row_count);