From 6b8cfc2d8ad4497f45424a8d09cf12163cc0c6b4 Mon Sep 17 00:00:00 2001 From: Jack Yu Date: Wed, 23 Aug 2023 19:44:33 +0800 Subject: [PATCH] binlog: fix the wrong fatal error when binlog is too large Signed-off-by: Jack Yu --- sessionctx/binloginfo/binloginfo.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sessionctx/binloginfo/binloginfo.go b/sessionctx/binloginfo/binloginfo.go index d871c10eed2ef..16b85c1464fa6 100644 --- a/sessionctx/binloginfo/binloginfo.go +++ b/sessionctx/binloginfo/binloginfo.go @@ -269,7 +269,7 @@ func (info *BinlogInfo) WriteBinlog(clusterID uint64) *WriteResult { return &WriteResult{true, nil} } - if strings.Contains(err.Error(), "received message larger than max") { + if strings.Contains(err.Error(), "message larger than max") { // This kind of error is not critical, return directly. return &WriteResult{false, errors.Errorf("binlog data is too large (%s)", err.Error())} }