From c21bf9396ae335d15c8221b06e38487c5912dbf3 Mon Sep 17 00:00:00 2001
From: iosmanthus <dengliming@pingcap.com>
Date: Mon, 13 Mar 2023 15:07:26 +0800
Subject: [PATCH] add api_version for mpp task meta (#738)

---
 internal/apicodec/codec.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/apicodec/codec.go b/internal/apicodec/codec.go
index 5e3b7538..be1a1365 100644
--- a/internal/apicodec/codec.go
+++ b/internal/apicodec/codec.go
@@ -98,6 +98,7 @@ func attachAPICtx(c Codec, req *tikvrpc.Request) (*tikvrpc.Request, error) {
 	case tikvrpc.CmdMPPTask:
 		mpp := *r.DispatchMPPTask()
 		mpp.Meta.KeyspaceId = ctx.KeyspaceId
+		mpp.Meta.ApiVersion = ctx.ApiVersion
 		r.Req = &mpp
 	case tikvrpc.CmdCompact:
 		compact := *r.Compact()