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

fix miss ret in group join buffer

Browse Source
This commit is contained in:
pe-99y
2024-12-04 08:15:37 +00:00
committed by ob-robot
parent f2f3a82170
commit 36d6ee19ac
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/sql/engine/basic/ob_group_join_buffer_v2.cpp
View File

@ -337,16 +337,19 @@ int ObDriverRowBuffer::batch_fill_group_buffer(const int64_t max_row_cnt)
if (batch_rows->size_ == 0 && batch_rows->end_) {
// do nothing
} else if (OB_FAIL(last_batch_.save(spec_->max_batch_size_))) {
LOG_WARN("failed to save last batch", K(ret));
} else {
last_batch_.save(spec_->max_batch_size_);
save_last_batch_ = true;
}
if (left_store_.get_row_cnt() <= 0) {
// this could happen if we have skipped all rows
ret = OB_ITER_END;
} else if (OB_FAIL(left_store_.begin(left_store_iter_))) {
LOG_WARN("begin iterator for chunk row store failed", KR(ret));
if (OB_SUCC(ret)) {
if (left_store_.get_row_cnt() <= 0) {
// this could happen if we have skipped all rows
ret = OB_ITER_END;
} else if (OB_FAIL(left_store_.begin(left_store_iter_))) {
LOG_WARN("begin iterator for chunk row store failed", KR(ret));
}
}
}
}