From a0e8cccf359450c60d1e4d37a268df102e984317 Mon Sep 17 00:00:00 2001 From: ekexium Date: Wed, 9 Oct 2024 15:49:44 +0800 Subject: [PATCH] set RequestSource for Broadcast msg Signed-off-by: ekexium --- txnkv/transaction/2pc.go | 1 + 1 file changed, 1 insertion(+) diff --git a/txnkv/transaction/2pc.go b/txnkv/transaction/2pc.go index 5ad4b5d4c..22df9a8a3 100644 --- a/txnkv/transaction/2pc.go +++ b/txnkv/transaction/2pc.go @@ -1412,6 +1412,7 @@ func broadcastToAllStores( ResourceGroupName: resourceGroupName, } req.Context.ResourceGroupTag = resourceGroupTag + req.Context.RequestSource = txn.GetRequestSource() _, err := store.GetTiKVClient().SendRequest( bo.GetCtx(),