diff --git a/src/sql/engine/ob_physical_plan.cpp b/src/sql/engine/ob_physical_plan.cpp index 37bf45344e..7826670747 100644 --- a/src/sql/engine/ob_physical_plan.cpp +++ b/src/sql/engine/ob_physical_plan.cpp @@ -140,7 +140,8 @@ ObPhysicalPlan::ObPhysicalPlan(MemoryContext &mem_context /* = CURRENT_CONTEXT * udf_has_dml_stmt_(false), mview_ids_(&allocator_), enable_inc_direct_load_(false), - enable_replace_(false) + enable_replace_(false), + insert_overwrite_(false) { } @@ -240,6 +241,7 @@ void ObPhysicalPlan::reset() mview_ids_.reset(); enable_inc_direct_load_ = false; enable_replace_ = false; + insert_overwrite_ = false; } void ObPhysicalPlan::destroy() { @@ -812,7 +814,8 @@ OB_SERIALIZE_MEMBER(ObPhysicalPlan, mview_ids_, enable_inc_direct_load_, enable_replace_, - immediate_refresh_external_table_ids_); + immediate_refresh_external_table_ids_, + insert_overwrite_); 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 3cd0ea1fbe..318f8005e2 100644 --- a/src/sql/engine/ob_physical_plan.h +++ b/src/sql/engine/ob_physical_plan.h @@ -702,6 +702,7 @@ private: common::ObFixedArray mview_ids_; bool enable_inc_direct_load_; // for incremental direct load bool enable_replace_; // for incremental direct load + bool insert_overwrite_; // for insert overwrite }; inline void ObPhysicalPlan::set_affected_last_insert_id(bool affected_last_insert_id)