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

[CP] force allocate exchange for first pdml operator

Browse Source
This commit is contained in:
obdev
2023-11-16 04:40:35 +00:00
committed by ob-robot
parent aa6c3e121a
commit 58c026ace0
2 changed files with 184 additions and 147 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/sql/optimizer/ob_del_upd_log_plan.cpp
View File

@ -994,16 +994,10 @@ int ObDelUpdLogPlan::create_pdml_delete_plan(ObLogicalOperator *&top,
IndexDMLInfo *index_dml_info)
{
int ret = OB_SUCCESS;
bool need_exchange = true;
if (OB_ISNULL(source_table_partition)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("get unexpected null", K(source_table_partition), K(ret));
} else if (!is_index_maintenance &&
OB_FAIL(check_need_exchange_for_pdml_del_upd(top, exch_info,
source_table_partition->get_table_id(),
need_exchange))) {
LOG_WARN("failed to check whether pdml need exchange for del upd", K(ret));
} else if (need_exchange && OB_FAIL(allocate_exchange_as_top(top, exch_info))) {
} else if (OB_FAIL(allocate_exchange_as_top(top, exch_info))) {
LOG_WARN("failed to allocate exchange as top", K(ret));
} else if (OB_FAIL(allocate_pdml_delete_as_top(top,
is_index_maintenance,
@ -1496,16 +1490,10 @@ int ObDelUpdLogPlan::create_pdml_update_plan(ObLogicalOperator *&top,
IndexDMLInfo *index_dml_info)
{
int ret = OB_SUCCESS;
bool need_exchange = true;
if (OB_ISNULL(source_table_partition)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("get unexpected null", K(source_table_partition), K(ret));
} else if (!is_index_maintenance &&
OB_FAIL(check_need_exchange_for_pdml_del_upd(top, exch_info,
source_table_partition->get_table_id(),
need_exchange))) {
LOG_WARN("failed to check pdml need exchange for del upd", K(ret));
} else if (OB_FAIL(need_exchange && allocate_exchange_as_top(top, exch_info))) {
} else if (OB_FAIL(allocate_exchange_as_top(top, exch_info))) {
LOG_WARN("failed to allocate exchange as top", K(ret));
} else if (OB_FAIL(allocate_pdml_update_as_top(top,
is_index_maintenance,