hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] [Fix] obkv batch op with same key

Browse Source
This commit is contained in:
obdev
2024-02-08 12:57:32 +00:00
committed by ob-robot
parent 8247829659
commit b4767c46d6
2 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/observer/table/ob_table_cg_service.cpp
View File

@ -2004,6 +2004,7 @@ int ObTableDmlCgService::generate_das_base_ctdef(uint64_t index_tid,
base_ctdef.index_tid_ = index_tid;
base_ctdef.is_ignore_ = false; // insert ignore
base_ctdef.is_batch_stmt_ = false;
base_ctdef.is_table_api_ = true;
int64_t binlog_row_image = share::ObBinlogRowImage::FULL;
ObSQLSessionInfo &session = ctx.get_session_info();

4
src/observer/table/ob_table_context.h
View File

@ -556,7 +556,6 @@ public:
column_infos_(alloc),
alloc_(alloc)
{
das_ctdef_.is_table_api_ = true;
}
TO_STRING_KV(K_(das_ctdef),
K_(related_ctdefs));
@ -596,7 +595,6 @@ public:
related_ins_ctdefs_(alloc),
alloc_(alloc)
{
das_ctdef_.is_table_api_ = true;
}
TO_STRING_KV(K_(full_row),
K_(delta_row),
@ -653,7 +651,6 @@ public:
related_ctdefs_(alloc),
alloc_(alloc)
{
das_ctdef_.is_table_api_ = true;
}
TO_STRING_KV(K_(das_ctdef),
K_(related_ctdefs));
@ -745,7 +742,6 @@ public:
das_ctdef_(alloc),
alloc_(alloc)
{
das_ctdef_.is_table_api_ = true;
}
TO_STRING_KV(K_(das_ctdef));
ObDASLockCtDef das_ctdef_;