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-02-09 15:09:27 +00:00
committed by ob-robot
parent 9a14caef15
commit 126ee828f8
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_; ObPxTaskChSet task_ch_set_;
bool iter_end_; bool iter_end_;
bool channel_linked_; bool channel_linked_;
common::ObArray<dtl::ObDtlChannel *> task_channels_; ObTMArray<dtl::ObDtlChannel *> task_channels_;
ObReceiveRowReader row_reader_; ObReceiveRowReader row_reader_;
ObPxReceiveRowP px_row_msg_proc_; ObPxReceiveRowP px_row_msg_proc_;
dtl::ObDtlFlowControl dfc_; 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()) { } else if (PARTITION_LEVEL_TWO != table_schema->get_part_level()) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected part level", K(ret)); 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)); LOG_WARN("fail create hashmap", K(ret));
} else { } else {
ObPartitionSchemaIter iter(*table_schema, CHECK_PARTITION_MODE_NORMAL); ObPartitionSchemaIter iter(*table_schema, CHECK_PARTITION_MODE_NORMAL);