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()