Skip to content

Commit 4976ef6

Browse files
add debug log (#23050)
add debug log Approved by: @XuPeng-SH
1 parent d11d420 commit 4976ef6

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

pkg/vm/engine/tae/txn/txnbase/mvccnode.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ import (
2121
"github.com/matrixorigin/matrixone/pkg/common/moerr"
2222
"github.com/matrixorigin/matrixone/pkg/container/types"
2323
"github.com/matrixorigin/matrixone/pkg/container/vector"
24+
"github.com/matrixorigin/matrixone/pkg/logutil"
2425
"github.com/matrixorigin/matrixone/pkg/vm/engine/tae/containers"
2526
"github.com/matrixorigin/matrixone/pkg/vm/engine/tae/iface/txnif"
2627
)
@@ -78,6 +79,7 @@ func (un *TxnMVCCNode) CheckConflict(txn txnif.TxnReader) error {
7879
if un.IsSameTxn(txn) {
7980
return nil
8081
}
82+
logutil.Infof("Dedup-WW, prev txn is %x, new txn is %x", un.Txn.GetID(), txn.GetID())
8183
return txnif.ErrTxnWWConflict
8284
}
8385

@@ -86,6 +88,7 @@ func (un *TxnMVCCNode) CheckConflict(txn txnif.TxnReader) error {
8688
// ts CommitTs time
8789
startTS := txn.GetStartTS()
8890
if un.End.GT(&startTS) {
91+
logutil.Infof("Dedup-WW, prev ts is %x, new txn is %x", un.End.ToString(), startTS.ToString())
8992
return txnif.ErrTxnWWConflict
9093
}
9194
return nil

pkg/vm/engine/tae/txn/txnimpl/base_table.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -198,7 +198,7 @@ func (tbl *baseTable) getRowsByPK(ctx context.Context, pks containers.Vector) (r
198198
common.WorkspaceAllocator,
199199
)
200200
if err != nil {
201-
logutil.Infof("getRowsByPK failed GetDuplicate: %v", err)
201+
logutil.Infof("getRowsByPK failed GetDuplicate: %v, obj %v", err, obj.ID().String())
202202
return
203203
}
204204
}

0 commit comments

Comments
 (0)