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

fix plan cache memleak for add local plan route

Browse Source
This commit is contained in:
jh
2021-06-22 20:29:47 +08:00
committed by MizuhaHimuraki
parent 524427c455
commit 00672c3c73
1 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/sql/plan_cache/ob_plan_set.cpp
View File

@ -901,14 +901,18 @@ int ObSqlPlanSet::add_plan(ObPhysicalPlan& plan, ObPlanCacheCtx& pc_ctx, int64_t
array_binding_plan_ = &plan; array_binding_plan_ = &plan;
} }
} else { } else {
local_plan_ = &plan; if (NULL != local_plan_) {
local_phy_locations_.reset(); ret = OB_SQL_PC_PLAN_DUPLICATE;
if (OB_FAIL(init_phy_location(phy_locations.count()))) { } else {
SQL_PC_LOG(WARN, "init phy location failed"); local_plan_ = &plan;
} else if (OB_FAIL(local_phy_locations_.assign(phy_locations))) { local_phy_locations_.reset();
SQL_PC_LOG(WARN, "fail to assign phy locations"); if (OB_FAIL(init_phy_location(phy_locations.count()))) {
SQL_PC_LOG(WARN, "init phy location failed");
} else if (OB_FAIL(local_phy_locations_.assign(phy_locations))) {
SQL_PC_LOG(WARN, "fail to assign phy locations");
}
LOG_DEBUG("local phy locations", K(local_phy_locations_));
} }
LOG_DEBUG("local phy locations", K(local_phy_locations_));
} }
} break; } break;
case OB_PHY_PLAN_REMOTE: { case OB_PHY_PLAN_REMOTE: {