From c349655f92e62c8d54c0be03eb6d123b8f7e23a5 Mon Sep 17 00:00:00 2001 From: eitamos Date: Tue, 17 Jan 2023 11:01:09 +0200 Subject: [PATCH] Change log debug level --- canal/sync.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/canal/sync.go b/canal/sync.go index 29226646d..231baa6eb 100644 --- a/canal/sync.go +++ b/canal/sync.go @@ -147,11 +147,11 @@ func (c *Canal) runSyncBinlog() error { if strings.Contains(strings.ToLower(msg), strings.ToLower("procedure")) { // Cut the first row from the message since it contain the procedure call and not the entire message fl := strings.Split(msg, "\n") - log.Errorf("parse SP Error: (%s)", fl[0]) + log.Debugf("parse SP Error: (%s)", fl[0]) } else { - log.Errorf("parse query(%s) err %v", e.Query, err) + log.Debugf("parse query(%s) err %v", e.Query, err) } - log.Error("will skip this event") + log.Debugln("will skip this event") continue } for _, stmt := range stmts {