From 1fa2752c1014cd381a398677844bf38acad8004d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Dani=C3=ABl=20van=20Eeden?= Date: Mon, 4 Dec 2023 12:32:52 +0100 Subject: [PATCH] syncer(dm): Improve logging of ignored TableMap/FormatDesc (#10205) close pingcap/tiflow#10204 --- dm/syncer/syncer.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/dm/syncer/syncer.go b/dm/syncer/syncer.go index 3e20b1158e6..7b8c067df53 100644 --- a/dm/syncer/syncer.go +++ b/dm/syncer/syncer.go @@ -2435,6 +2435,8 @@ func (s *Syncer) Run(ctx context.Context) (err error) { case *replication.XIDEvent: eventType = "XID" needContinue, err2 = funcCommit() + case *replication.TableMapEvent: + case *replication.FormatDescriptionEvent: default: s.tctx.L().Warn("unhandled event from transaction payload", zap.String("type", fmt.Sprintf("%T", tpevt))) } @@ -2442,6 +2444,8 @@ func (s *Syncer) Run(ctx context.Context) (err error) { if needContinue { continue } + case *replication.TableMapEvent: + case *replication.FormatDescriptionEvent: default: s.tctx.L().Warn("unhandled event", zap.String("type", fmt.Sprintf("%T", ev))) }