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

Resolve a series of out-of-memory issues within 500 tenant

Browse Source
This commit is contained in:
obdev
2024-01-17 16:12:40 +00:00
committed by ob-robot
parent 55bd25346e
commit 567cdc7229
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/engine/px/exchange/ob_px_receive_op.h
View File

@ -169,7 +169,7 @@ protected:
ObPxTaskChSet task_ch_set_;
bool iter_end_;
bool channel_linked_;
common::ObArray<dtl::ObDtlChannel *> task_channels_;
ObTMArray<dtl::ObDtlChannel *> task_channels_;
ObReceiveRowReader row_reader_;
ObPxReceiveRowP px_row_msg_proc_;
dtl::ObDtlFlowControl dfc_;

5
src/sql/engine/px/ob_granule_iterator_op.cpp
View File

@ -1170,7 +1170,10 @@ int ObGranuleIteratorOp::try_build_tablet2part_id_map()
} else if (PARTITION_LEVEL_TWO != table_schema->get_part_level()) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected part level", K(ret));
} else if (OB_FAIL(tablet2part_id_map_.create(max(1, table_schema->get_all_part_num()), "GITabletMap"))) {
} else if (OB_FAIL(tablet2part_id_map_.create(max(1, table_schema->get_all_part_num()),
"GITabletMap",
ObModIds::OB_HASH_NODE,
MTL_ID()))) {
LOG_WARN("fail create hashmap", K(ret));
} else {
ObPartitionSchemaIter iter(*table_schema, CHECK_PARTITION_MODE_NORMAL);