From b4767c46d6765670f6d76a3f8b4a295c9d1f663b Mon Sep 17 00:00:00 2001
From: obdev <obdev@oceanbase.com>
Date: Thu, 8 Feb 2024 12:57:32 +0000
Subject: [PATCH] [CP] [Fix] obkv batch op with same key

---
 src/observer/table/ob_table_cg_service.cpp | 1 +
 src/observer/table/ob_table_context.h      | 4 ----
 2 files changed, 1 insertion(+), 4 deletions(-)

diff --git a/src/observer/table/ob_table_cg_service.cpp b/src/observer/table/ob_table_cg_service.cpp
index 0d68e30dbb..82eb9b60e4 100644
--- a/src/observer/table/ob_table_cg_service.cpp
+++ b/src/observer/table/ob_table_cg_service.cpp
@@ -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();
 
diff --git a/src/observer/table/ob_table_context.h b/src/observer/table/ob_table_context.h
index a30f899e80..a08a0a990b 100644
--- a/src/observer/table/ob_table_context.h
+++ b/src/observer/table/ob_table_context.h
@@ -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_;