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

修复merge rollup的op ordering计算不对的问题

Browse Source
This commit is contained in:
zzg19950727 2024-11-04 10:44:48 +00:00 committed by ob-robot
parent 5908fe85b7
commit 2228b91b82
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/sql/optimizer/ob_log_group_by.cpp
View File

@ -703,12 +703,16 @@ int ObLogGroupBy::compute_op_ordering()
ObSEArray<OrderItem, 4> ordering;
// for rollup distributor, sort key is inner
if (ObRollupStatus::ROLLUP_DISTRIBUTOR != rollup_adaptive_info_.rollup_status_) {
for (int64_t i = 0; OB_SUCC(ret) && i < group_exprs_.count(); i++) {
bool has_ordering = true;
for (int64_t i = 0; OB_SUCC(ret) && has_ordering && i < group_exprs_.count(); i++) {
if (i < child->get_op_ordering().count() &&
child->get_op_ordering().at(i).expr_ == group_exprs_.at(i) &&
OB_FAIL(ordering.push_back(child->get_op_ordering().at(i)))) {
LOG_WARN("failed to push back into ordering.", K(ret));
} else {}
child->get_op_ordering().at(i).expr_ == group_exprs_.at(i)) {
if (OB_FAIL(ordering.push_back(child->get_op_ordering().at(i)))) {
LOG_WARN("failed to push back into ordering.", K(ret));
}
} else {
has_ordering = false;
}
}
}
if (OB_SUCC(ret) && OB_FAIL(set_op_ordering(ordering))) {