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

fix merge join dynamic memleak

Browse Source
This commit is contained in:
obdev
2023-07-24 08:42:41 +00:00
committed by ob-robot
parent 283a9c0b9a
commit ae0cd73243
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/sql/engine/join/ob_merge_join_op.h
View File

@ -267,7 +267,7 @@ private:
// When the other fetcher is end, we start to iterator this fetcher and outptu until end. // When the other fetcher is end, we start to iterator this fetcher and outptu until end.
// At the beginning, there are some rows in the current batch that not output yet. // At the beginning, there are some rows in the current batch that not output yet.
// We need store these rows and output first, then get batch from child and output directly. // We need store these rows and output first, then get batch from child and output directly.
ObSEArray<ObDatum *, 256, common::ModulePageAllocator, true> backup_datums_; ObSEArray<ObDatum *, 256> backup_datums_;
int64_t backup_rows_cnt_; int64_t backup_rows_cnt_;
ObBatchResultHolder brs_holder_; ObBatchResultHolder brs_holder_;
@ -524,9 +524,9 @@ private:
}; };
int64_t cmp_res_; int64_t cmp_res_;
ObSEArray<RowsListPair, 256, common::ModulePageAllocator, true> match_groups_; ObSEArray<RowsListPair, 256> match_groups_;
bool is_last_right_join_output_; bool is_last_right_join_output_;
ObSEArray<RowsPair, 256, common::ModulePageAllocator, true> output_cache_; ObSEArray<RowsPair, 256> output_cache_;
ObBitVector *rj_match_vec_; // bitmap to check whether it is matched during right join ObBitVector *rj_match_vec_; // bitmap to check whether it is matched during right join
int64_t rj_match_vec_size_; // size of `rj_match_vec_` int64_t rj_match_vec_size_; // size of `rj_match_vec_`
ObRADatumStore::IterationAge output_rows_it_age_; ObRADatumStore::IterationAge output_rows_it_age_;