From 078d6c0c34cfc53b5e1ddc3e312563b503cded32 Mon Sep 17 00:00:00 2001 From: hongyunyan <649330952@qq.com> Date: Tue, 28 Apr 2026 19:44:08 +0800 Subject: [PATCH 1/2] update --- maintainer/maintainer.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/maintainer/maintainer.go b/maintainer/maintainer.go index 7938b5c9bd..32ae30b4fe 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 ) From 263625ba61ee51699f47156ad090333bed2795ad Mon Sep 17 00:00:00 2001 From: hongyunyan <649330952@qq.com> Date: Tue, 28 Apr 2026 19:46:32 +0800 Subject: [PATCH 2/2] update --- maintainer/maintainer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/maintainer/maintainer.go b/maintainer/maintainer.go index 32ae30b4fe..47c0bc6669 100644 --- a/maintainer/maintainer.go +++ b/maintainer/maintainer.go @@ -309,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",