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_;