diff --git a/deps/oblib/src/rpc/obrpc/ob_rpc_packet_list.h b/deps/oblib/src/rpc/obrpc/ob_rpc_packet_list.h index aede9da615..82551f356a 100644 --- a/deps/oblib/src/rpc/obrpc/ob_rpc_packet_list.h +++ b/deps/oblib/src/rpc/obrpc/ob_rpc_packet_list.h @@ -1173,6 +1173,7 @@ PCODE_DEF(OB_GENERATE_AUX_INDEX_SCHEMA, 0x1626) //PCODE_DEF(OB_GET_SS_MICRO_BLOCK_META, 0x162A) //PCODE_DEF(OB_GET_LS_REQUIRED_SIZE, 0x162B) //PCODE_DEF(OB_DEL_SS_TABLET_META, 0x162C) +//PCODE_DEF(OB_CHECK_AUX_INDEX_SCHEMA_EXIST, 0x162D) //**** 注意:在此行之前增加新的RPC ID ****** // diff --git a/src/sql/engine/ob_physical_plan.cpp b/src/sql/engine/ob_physical_plan.cpp index 2f9b618222..8c616bf926 100644 --- a/src/sql/engine/ob_physical_plan.cpp +++ b/src/sql/engine/ob_physical_plan.cpp @@ -144,7 +144,8 @@ ObPhysicalPlan::ObPhysicalPlan(MemoryContext &mem_context /* = CURRENT_CONTEXT * insert_overwrite_(false), online_sample_percent_(1.), can_set_feedback_info_(true), - need_switch_to_table_lock_worker_(false) + need_switch_to_table_lock_worker_(false), + data_complement_gen_doc_id_(false) { } @@ -248,6 +249,7 @@ void ObPhysicalPlan::reset() online_sample_percent_ = 1.; can_set_feedback_info_.store(true); need_switch_to_table_lock_worker_ = false; + data_complement_gen_doc_id_ = false; } void ObPhysicalPlan::destroy() { @@ -823,7 +825,8 @@ OB_SERIALIZE_MEMBER(ObPhysicalPlan, immediate_refresh_external_table_ids_, insert_overwrite_, online_sample_percent_, - need_switch_to_table_lock_worker_); + need_switch_to_table_lock_worker_, + data_complement_gen_doc_id_); 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 886313e65c..810d5311da 100644 --- a/src/sql/engine/ob_physical_plan.h +++ b/src/sql/engine/ob_physical_plan.h @@ -711,6 +711,7 @@ private: double online_sample_percent_; // for incremental direct load std::atomic can_set_feedback_info_; bool need_switch_to_table_lock_worker_; // for table lock switch worker thread + bool data_complement_gen_doc_id_; }; inline void ObPhysicalPlan::set_affected_last_insert_id(bool affected_last_insert_id)