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 }