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

Fix get decimal int aggr ctx coredump in window function pushdown

Browse Source
This commit is contained in:
hezuojiao
2023-11-15 10:10:29 +00:00
committed by ob-robot
parent df9f15b360
commit 377c59a57e
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/sql/engine/window_function/ob_window_function_op.cpp
View File

@ -1702,8 +1702,12 @@ int ObWindowFunctionOp::compute_push_down_by_pass(WinFuncCell &wf_cell, common::
LOG_WARN("wf_cell is not aggr", K(ret)); LOG_WARN("wf_cell is not aggr", K(ret));
} else { } else {
AggrCell *aggr_func = static_cast<AggrCell *>(&wf_cell); AggrCell *aggr_func = static_cast<AggrCell *>(&wf_cell);
if (OB_FAIL(aggr_func->aggr_processor_.fast_single_row_agg( if (OB_UNLIKELY(1 != aggr_func->aggr_processor_.get_aggr_infos().count())) {
eval_ctx_, wf_cell.wf_info_.aggr_info_))) { ret = OB_ERR_UNEXPECTED;
LOG_WARN("aggr infos count mismatch", K(ret),
K(aggr_func->aggr_processor_.get_aggr_infos().count()));
} else if (OB_FAIL(aggr_func->aggr_processor_.fast_single_row_agg(
eval_ctx_, aggr_func->aggr_processor_.get_aggr_infos().at(0)))) {
LOG_WARN("fast_single_row_one_aggr_info failed", K(ret)); LOG_WARN("fast_single_row_one_aggr_info failed", K(ret));
} else { } else {
ObDatum &result_datum = wf_cell.wf_info_.aggr_info_.expr_->locate_expr_datum(eval_ctx_); ObDatum &result_datum = wf_cell.wf_info_.aggr_info_.expr_->locate_expr_datum(eval_ctx_);