diff --git a/src/sql/engine/ob_physical_plan.cpp b/src/sql/engine/ob_physical_plan.cpp
index cc73456b53..866c549297 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 *
     all_local_session_vars_(&allocator_),
     udf_has_dml_stmt_(false),
     mview_ids_(&allocator_),
-    enable_inc_direct_load_(false)
+    enable_inc_direct_load_(false),
+    enable_replace_(false)
 {
 }
 
@@ -235,6 +236,7 @@ void ObPhysicalPlan::reset()
   udf_has_dml_stmt_ = false;
   mview_ids_.reset();
   enable_inc_direct_load_ = false;
+  enable_replace_ = false;
 }
 void ObPhysicalPlan::destroy()
 {
@@ -797,7 +799,8 @@ OB_SERIALIZE_MEMBER(ObPhysicalPlan,
                     udf_has_dml_stmt_,
                     stat_.format_sql_id_,
                     mview_ids_,
-                    enable_inc_direct_load_);
+                    enable_inc_direct_load_,
+                    enable_replace_);
 
 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 c95f66761d..fbab0c9809 100644
--- a/src/sql/engine/ob_physical_plan.h
+++ b/src/sql/engine/ob_physical_plan.h
@@ -371,6 +371,11 @@ public:
   {
     enable_inc_direct_load_ = enable_inc_direct_load;
   }
+  inline bool get_enable_replace() const { return enable_replace_; }
+  inline void set_enable_replace(const bool enable_replace)
+  {
+    enable_replace_ = enable_replace;
+  }
 
 public:
   int inc_concurrent_num();
@@ -691,6 +696,7 @@ public:
 private:
   common::ObFixedArray<uint64_t, common::ObIAllocator> mview_ids_;
   bool enable_inc_direct_load_; // for incremental direct load
+  bool enable_replace_; // for incremental direct load
 };
 
 inline void ObPhysicalPlan::set_affected_last_insert_id(bool affected_last_insert_id)