diff --git a/maintainer/maintainer.go b/maintainer/maintainer.go index 7938b5c9bd..47c0bc6669 100644 --- a/maintainer/maintainer.go +++ b/maintainer/maintainer.go @@ -47,7 +47,8 @@ import ( ) const ( - periodEventInterval = time.Millisecond * 100 + //periodEventInterval = time.Millisecond * 100 + periodEventInterval = time.Second * 120 periodRedoInterval = time.Second * 1 ) @@ -308,7 +309,7 @@ func (m *Maintainer) HandleEvent(event *Event) bool { zap.Stringer("changefeedID", m.changefeedID), zap.Int("eventType", event.eventType), zap.Duration("duration", duration), - zap.Any("Message", event.message), + zap.Any("MessageType", event.message.Type), ) } else { log.Info("maintainer is too slow",