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

fix temp table execute bug

Browse Source
This commit is contained in:
zzg19950727
2023-08-04 02:48:24 +00:00
committed by ob-robot
parent 042994856f
commit 78c6cbd670
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/sql/engine/basic/ob_temp_table_transformation_op.cpp
View File

@ -65,8 +65,10 @@ int ObTempTableTransformationOp::inner_get_next_row()
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
clear_evaluated_flag(); clear_evaluated_flag();
ObExecContext &ctx = get_exec_ctx();
if (init_temp_table_) { if (init_temp_table_) {
for (int64_t i = 0; OB_SUCC(ret) && i < get_child_cnt() - 1; ++i) { for (int64_t i = 0; OB_SUCC(ret) && i < get_child_cnt() - 1; ++i) {
int64_t temp_table_count = ctx.get_temp_table_ctx().count();
if (OB_ISNULL(children_[i])) { if (OB_ISNULL(children_[i])) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
LOG_WARN("child op is null"); LOG_WARN("child op is null");
@ -75,6 +77,13 @@ int ObTempTableTransformationOp::inner_get_next_row()
LOG_WARN("failed to get next row.", K(ret)); LOG_WARN("failed to get next row.", K(ret));
} else { } else {
ret = OB_SUCCESS; ret = OB_SUCCESS;
while(OB_SUCC(ret) && ctx.get_temp_table_ctx().count() <= temp_table_count) {
if (OB_FAIL(check_status())) {
LOG_WARN("failed to wait temp table finish msg", K(ret));
} else {
ob_usleep(1000);
}
}
} }
} }
init_temp_table_ = false; init_temp_table_ = false;