From d8cb72a4e0198c8864738dba7d162c26c3f0c9fa Mon Sep 17 00:00:00 2001 From: jiangxinmeng1 Date: Wed, 6 Nov 2024 14:33:42 +0800 Subject: [PATCH] fix --- pkg/vm/engine/tae/txn/txnimpl/table.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/pkg/vm/engine/tae/txn/txnimpl/table.go b/pkg/vm/engine/tae/txn/txnimpl/table.go index 26f8fd8af25f..c53adb55e80c 100644 --- a/pkg/vm/engine/tae/txn/txnimpl/table.go +++ b/pkg/vm/engine/tae/txn/txnimpl/table.go @@ -484,7 +484,14 @@ func (tbl *txnTable) recurTransferDelete( //check if the target block had been soft deleted and committed before ts, //if not, transfer the deletes to the target block, //otherwise recursively transfer the deletes to the next target block. - err := tbl.store.warChecker.checkOne(newID, ts) + obj, err := tbl.store.warChecker.CacheGet(newID.DbID, newID.TableID, newID.ObjectID(), false) + if err != nil { + return err + } + err = readWriteConfilictCheck( + obj, + ts, + ) if err == nil { pkVec := tbl.store.rt.VectorPool.Small.GetVector(pkType) pkVec.Append(pk, false)