diff --git a/worker/restore_map.go b/worker/restore_map.go index ef48590b183..355d4369cd5 100644 --- a/worker/restore_map.go +++ b/worker/restore_map.go @@ -379,6 +379,7 @@ func (m *mapper) processReqCh(ctx context.Context) error { if err := update.Unmarshal(kv.Value); err != nil { return err } + update.TypeName = x.GalaxyAttr(update.TypeName) for _, sch := range update.Fields { sch.Predicate = x.GalaxyAttr(sch.Predicate) }