diff --git a/cdc/entry/schema/snapshot.go b/cdc/entry/schema/snapshot.go index a63608b2770..b74dded5791 100644 --- a/cdc/entry/schema/snapshot.go +++ b/cdc/entry/schema/snapshot.go @@ -134,6 +134,7 @@ func NewSnapshotFromMeta( // `tag` is used to reverse sort all versions in the generated snapshot. tag := negative(currentTs) for _, dbinfo := range dbinfos { + log.Info("load database", zap.Int64("dbID", dbinfo.ID), zap.Stringer("db", dbinfo.Name), zap.Stringer("changefeed", id)) if filter.ShouldIgnoreSchema(dbinfo.Name.O) { log.Debug("ignore database", zap.Stringer("db", dbinfo.Name), zap.Stringer("changefeed", id)) continue @@ -178,6 +179,7 @@ func NewSnapshotFromMeta( } for _, tableInfo := range tableInfos { + log.Info("load table", zap.Int64("tableID", tableInfo.ID), zap.Stringer("name", tableInfo.Name), zap.Stringer("changefeed", id)) tableInfo := model.WrapTableInfo(dbinfo.ID, dbinfo.Name.O, currentTs, tableInfo) tableCount++ snap.inner.tables.ReplaceOrInsert(versionedID{