[CP] [Fix] obkv same rk in batch
This commit is contained in:
@ -51,6 +51,7 @@ public:
|
||||
K_(is_ignore),
|
||||
K_(is_batch_stmt),
|
||||
K_(is_insert_up),
|
||||
K_(is_table_api),
|
||||
K_(tz_info),
|
||||
K_(table_param),
|
||||
K_(encrypt_meta));
|
||||
@ -74,7 +75,8 @@ public:
|
||||
uint64_t is_ignore_ : 1;
|
||||
uint64_t is_batch_stmt_ : 1;
|
||||
uint64_t is_insert_up_ : 1;
|
||||
uint64_t reserved_ : 61;
|
||||
uint64_t is_table_api_ : 1;
|
||||
uint64_t reserved_ : 59;
|
||||
};
|
||||
};
|
||||
protected:
|
||||
|
||||
@ -1163,6 +1163,9 @@ int ObDMLService::init_dml_param(const ObDASDMLBaseCtDef &base_ctdef,
|
||||
if (base_ctdef.is_insert_up_) {
|
||||
dml_param.write_flag_.set_is_insert_up();
|
||||
}
|
||||
if (base_ctdef.is_table_api_) {
|
||||
dml_param.write_flag_.set_is_table_api();
|
||||
}
|
||||
if (dml_param.table_param_->get_data_table().is_storage_index_table()
|
||||
&& !dml_param.table_param_->get_data_table().can_read_index()) {
|
||||
dml_param.write_flag_.set_is_write_only_index();
|
||||
|
||||
Reference in New Issue
Block a user