diff --git a/internal/proxy/task_query.go b/internal/proxy/task_query.go index 910227e796135..9e43e1d3ef42b 100644 --- a/internal/proxy/task_query.go +++ b/internal/proxy/task_query.go @@ -570,6 +570,7 @@ func (t *queryTask) queryShard(ctx context.Context, nodeID int64, qn types.Query retrieveReq.GetBase().TargetID = nodeID if needOverrideMvcc && mvccTs > 0 { retrieveReq.MvccTimestamp = mvccTs + retrieveReq.GuaranteeTimestamp = mvccTs } req := &querypb.QueryRequest{