From 596b79404dd516f686a3b472b0957ebfc5938208 Mon Sep 17 00:00:00 2001 From: glorv Date: Mon, 27 Feb 2023 16:39:23 +0800 Subject: [PATCH] set group name in twoPhaseCommitter (#718) Signed-off-by: glorv --- txnkv/transaction/2pc.go | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/txnkv/transaction/2pc.go b/txnkv/transaction/2pc.go index cd32deb4..8e299b76 100644 --- a/txnkv/transaction/2pc.go +++ b/txnkv/transaction/2pc.go @@ -454,14 +454,15 @@ func (c *PlainMutations) AppendMutation(mutation PlainMutation) { // newTwoPhaseCommitter creates a twoPhaseCommitter. func newTwoPhaseCommitter(txn *KVTxn, sessionID uint64) (*twoPhaseCommitter, error) { return &twoPhaseCommitter{ - store: txn.store, - txn: txn, - startTS: txn.StartTS(), - sessionID: sessionID, - regionTxnSize: map[uint64]int{}, - isPessimistic: txn.IsPessimistic(), - binlog: txn.binlog, - diskFullOpt: kvrpcpb.DiskFullOpt_NotAllowedOnFull, + store: txn.store, + txn: txn, + startTS: txn.StartTS(), + sessionID: sessionID, + regionTxnSize: map[uint64]int{}, + isPessimistic: txn.IsPessimistic(), + binlog: txn.binlog, + diskFullOpt: kvrpcpb.DiskFullOpt_NotAllowedOnFull, + resourceGroupName: txn.resourceGroupName, }, nil }