From 644822b00276aec73eb3bb6b8f1eab516c82b161 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Dani=C3=ABl=20van=20Eeden?= Date: Fri, 28 Feb 2025 13:48:45 +0100 Subject: [PATCH] replication: Set source_binlog_checksum as well --- replication/binlogsyncer.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/replication/binlogsyncer.go b/replication/binlogsyncer.go index 2785a8505..318905661 100644 --- a/replication/binlogsyncer.go +++ b/replication/binlogsyncer.go @@ -319,13 +319,9 @@ func (b *BinlogSyncer) registerSlave() error { // necessary checksummed. // That preference is specified below. - if _, err = b.c.Execute(`SET @master_binlog_checksum='NONE'`); err != nil { + if _, err = b.c.Execute(`SET @master_binlog_checksum='NONE', @source_binlog_checksum='NONE'`); err != nil { return errors.Trace(err) } - - // if _, err = b.c.Execute(`SET @master_binlog_checksum=@@global.binlog_checksum`); err != nil { - // return errors.Trace(err) - // } } }