From 7baf3f417fbbb9f174320030bd85238bbb924f90 Mon Sep 17 00:00:00 2001 From: obdev Date: Wed, 7 Feb 2024 13:15:08 +0000 Subject: [PATCH] Fix decimalint in groupby pushdown --- src/storage/access/ob_pushdown_aggregate.cpp | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/src/storage/access/ob_pushdown_aggregate.cpp b/src/storage/access/ob_pushdown_aggregate.cpp index 34e3089ca6..9ab8bd7846 100644 --- a/src/storage/access/ob_pushdown_aggregate.cpp +++ b/src/storage/access/ob_pushdown_aggregate.cpp @@ -2999,12 +2999,9 @@ int ObGroupByCell::extract_distinct() int16_t &distinct_projector = distinct_projector_buf_->at(ref); if (-1 == distinct_projector) { // distinct val is not extracted yet - if (ob_is_decimal_int(group_by_col_expr_->datum_meta_.type_)) { - group_by_col_datums[distinct_cnt_].set_decimal_int(tmp_group_by_datums[ref].get_decimal_int(), tmp_group_by_datums[ref].len_); - } else if (OB_FAIL(group_by_col_datums[distinct_cnt_].from_storage_datum(tmp_group_by_datums[ref], group_by_col_expr_->obj_datum_map_))) { + if (OB_FAIL(group_by_col_datums[distinct_cnt_].from_storage_datum(tmp_group_by_datums[ref], group_by_col_expr_->obj_datum_map_))) { LOG_WARN("Failed to clone datum", K(ret), K(tmp_group_by_datums[ref]), K(group_by_col_expr_->obj_datum_map_)); - } - if (OB_SUCC(ret)) { + } else { distinct_projector = distinct_cnt_; ref = distinct_cnt_; distinct_cnt_++;