binlog: fix the wrong fatal error when binlog is too large (pingcap#4…

…6365) close pingcap#28659
jackysp · Aug 24, 2023 · 711e6c9 · 711e6c9
1 parent 973e246
commit 711e6c9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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())}
 		}