From ae3370491d61545e5fa490f98fc7fd4d55260647 Mon Sep 17 00:00:00 2001 From: sdc Date: Tue, 11 Mar 2025 04:16:15 +0000 Subject: [PATCH] serialization occupy position --- src/sql/engine/ob_physical_plan.cpp | 7 +++++-- src/sql/engine/ob_physical_plan.h | 1 + 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/src/sql/engine/ob_physical_plan.cpp b/src/sql/engine/ob_physical_plan.cpp index 17950598b9..c64cd6fcd3 100644 --- a/src/sql/engine/ob_physical_plan.cpp +++ b/src/sql/engine/ob_physical_plan.cpp @@ -137,7 +137,8 @@ ObPhysicalPlan::ObPhysicalPlan(MemoryContext &mem_context /* = CURRENT_CONTEXT * insertup_can_do_gts_opt_(false), px_node_policy_(ObPxNodePolicy::INVALID), px_node_addrs_(&allocator_), - px_node_count_(ObPxNodeHint::UNSET_PX_NODE_COUNT) + px_node_count_(ObPxNodeHint::UNSET_PX_NODE_COUNT), + px_worker_share_plan_enabled_(false) { } @@ -252,6 +253,7 @@ void ObPhysicalPlan::reset() px_node_policy_ = ObPxNodePolicy::INVALID; px_node_count_ = ObPxNodeHint::UNSET_PX_NODE_COUNT; px_node_addrs_.reset(); + px_worker_share_plan_enabled_ = false; } void ObPhysicalPlan::destroy() { @@ -898,7 +900,8 @@ OB_SERIALIZE_MEMBER(ObPhysicalPlan, px_parallel_rule_, px_node_policy_, px_node_addrs_, - px_node_count_); + px_node_count_, + px_worker_share_plan_enabled_); int ObPhysicalPlan::set_table_locations(const ObTablePartitionInfoArray &infos, ObSchemaGetterGuard &schema_guard) diff --git a/src/sql/engine/ob_physical_plan.h b/src/sql/engine/ob_physical_plan.h index 66ada82ca7..462f7a23a4 100644 --- a/src/sql/engine/ob_physical_plan.h +++ b/src/sql/engine/ob_physical_plan.h @@ -782,6 +782,7 @@ private: ObPxNodePolicy px_node_policy_; common::ObFixedArray px_node_addrs_; int64_t px_node_count_; + int64_t px_worker_share_plan_enabled_; }; inline void ObPhysicalPlan::set_affected_last_insert_id(bool affected_last_insert_id)