diff --git a/src/gausskernel/storage/cstore/cstore_update.cpp b/src/gausskernel/storage/cstore/cstore_update.cpp index d5db3430c..0dc051629 100644 --- a/src/gausskernel/storage/cstore/cstore_update.cpp +++ b/src/gausskernel/storage/cstore/cstore_update.cpp @@ -312,8 +312,9 @@ void CStoreUpdate::BatchDeleteAndInsert(VectorBatch *batch, int oriBatchCols, in if (needInsert) { { AutoContextSwitch updateContext(updateCnxt); - m_insert->BatchInsertCommon(bufferedBatchRows, options); + m_delete->PartialDelete(); } + m_insert->BatchInsertCommon(bufferedBatchRows, options); bufferedBatchRows->reset(true); lastStartIdx = startIdx; } else {