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

[CP] Fix merge groupby memory usage when processor has extra

Browse Source
This commit is contained in:
hezuojiao
2024-06-17 18:55:14 +00:00
committed by ob-robot
parent bb171a5b97
commit 4733a9f8e6
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/sql/engine/aggregate/ob_aggregate_processor.h
View File

@ -693,6 +693,7 @@ public:
} }
inline void set_in_window_func() { in_window_func_ = true; } inline void set_in_window_func() { in_window_func_ = true; }
inline bool has_distinct() const { return has_distinct_; } inline bool has_distinct() const { return has_distinct_; }
inline bool has_extra() const { return has_extra_; }
inline bool has_order_by() const { return has_order_by_; } inline bool has_order_by() const { return has_order_by_; }
RemovalInfo &get_removal_info() { return removal_info_; } RemovalInfo &get_removal_info() { return removal_info_; }

2
src/sql/engine/aggregate/ob_merge_groupby_op.cpp
View File

@ -270,7 +270,7 @@ int ObMergeGroupByOp::init()
} }
LOG_DEBUG("debug distinct exprs", K(ret), K(MY_SPEC.distinct_exprs_.count())); LOG_DEBUG("debug distinct exprs", K(ret), K(MY_SPEC.distinct_exprs_.count()));
} }
if (OB_SUCC(ret) && aggr_processor_.has_distinct()) { if (OB_SUCC(ret) && aggr_processor_.has_extra()) {
// set group_batch_factor_ to 1 avoid out of memory error // set group_batch_factor_ to 1 avoid out of memory error
group_batch_factor_ = 1; group_batch_factor_ = 1;
} }