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

fix temp table access rescan bug

Browse Source
This commit is contained in:
qingsuijiu
2024-04-24 06:19:51 +00:00
committed by ob-robot
parent 1eff2ece62
commit bc062e48a6
1 changed files with 32 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
src/sql/engine/basic/ob_temp_table_access_vec_op.cpp
View File

@ -170,9 +170,39 @@ OB_SERIALIZE_MEMBER_INHERIT(ObTempTableAccessVecOpSpec, ObOpSpec,
int ObTempTableAccessVecOp::inner_rescan()
{
int ret = OB_SUCCESS;
is_started_ = false;
int64_t result_id = 0;
cur_idx_ = 0;
return ObOperator::inner_rescan();
is_started_ = false;
can_rescan_ = true;
if (!MY_SPEC.is_distributed_) {
interm_result_ids_.reuse();
if (OB_FAIL(get_local_interm_result_id(result_id))) {
LOG_WARN("failed to get local result id", K(ret));
} else if (OB_FAIL(interm_result_ids_.push_back(result_id))) {
LOG_WARN("failed to push back result id", K(ret));
}
} else {
int64_t index = 0;
bool is_end = false;
while (!is_end && OB_SUCC(ret)) {
if (OB_FAIL(check_status())) {
LOG_WARN("check status failed", K(ret));
} else
if (OB_FAIL(MY_INPUT.check_finish(is_end, index))) {
LOG_WARN("failed to check finish.", K(ret));
} else if (!is_end) {
result_id = MY_INPUT.interm_result_ids_.at(index);
if (OB_FAIL(interm_result_ids_.push_back(result_id))) {
LOG_WARN("failed to push back result id", K(ret));
}
}
}
}
if (OB_SUCC(ret) &&
OB_FAIL(ObOperator::inner_rescan())) {
LOG_WARN("failed to rescan", K(ret));
}
return ret;
}
int ObTempTableAccessVecOp::inner_open()
@ -243,7 +273,6 @@ int ObTempTableAccessVecOp::inner_get_next_batch(const int64_t max_row_cnt)
if (is_end) {
brs_.size_ = 0;
brs_.end_ = true;
can_rescan_ = true;
} else {
brs_.size_ = read_rows;
}