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

fix bug reset_datum_ptr for all das_result_ouput_expr may case performance regression

Browse Source
This commit is contained in:
yishenglanlingzui 2023-05-09 07:45:32 +00:00 committed by ob-robot
parent 2f527f0595
commit 1b2d159c09
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/sql/das/ob_das_scan_op.cpp
View File

@ -442,9 +442,10 @@ void ObDASScanOp::reset_access_datums_ptr()
ObEvalInfo &info = (*e)->get_eval_info(*scan_rtdef_->eval_ctx_);
info.point_to_frame_ = true;
}
FOREACH_CNT(e, get_result_outputs()) {
(*e)->locate_datums_for_update(*scan_rtdef_->eval_ctx_, scan_rtdef_->eval_ctx_->max_batch_size_);
ObEvalInfo &info = (*e)->get_eval_info(*scan_rtdef_->eval_ctx_);
if (OB_NOT_NULL(scan_ctdef_->trans_info_expr_)) {
ObExpr *trans_expr = scan_ctdef_->trans_info_expr_;
trans_expr->locate_datums_for_update(*scan_rtdef_->eval_ctx_, scan_rtdef_->eval_ctx_->max_batch_size_);
ObEvalInfo &info = trans_expr->get_eval_info(*scan_rtdef_->eval_ctx_);
info.point_to_frame_ = true;
}
}
@ -455,6 +456,13 @@ void ObDASScanOp::reset_access_datums_ptr()
ObEvalInfo &info = (*e)->get_eval_info(*get_lookup_rtdef()->eval_ctx_);
info.point_to_frame_ = true;
}
if (OB_NOT_NULL(get_lookup_ctdef()->trans_info_expr_)) {
ObExpr *trans_expr = get_lookup_ctdef()->trans_info_expr_;
trans_expr->locate_datums_for_update(*get_lookup_rtdef()->eval_ctx_,
get_lookup_rtdef()->eval_ctx_->max_batch_size_);
ObEvalInfo &info = trans_expr->get_eval_info(*scan_rtdef_->eval_ctx_);
info.point_to_frame_ = true;
}
}
}