diff --git a/ddl/index_cop.go b/ddl/index_cop.go index fab097727139b..da9d4e397a6cb 100644 --- a/ddl/index_cop.go +++ b/ddl/index_cop.go @@ -428,6 +428,8 @@ func (c *copContext) buildTableScan(ctx context.Context, startTS uint64, start, SetFromInfoSchema(c.sessCtx.GetDomainInfoSchema()). SetConcurrency(1). Build() + kvReq.RequestSource.RequestSourceInternal = true + kvReq.RequestSource.RequestSourceType = getDDLRequestSource(model.ActionAddIndex) if err != nil { return nil, err }