From 89fb4405fe21866e1f8334c0d4210ac8602c3173 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Dani=C3=ABl=20van=20Eeden?= Date: Sat, 1 Mar 2025 09:27:23 +0100 Subject: [PATCH] replication: Set source_binlog_checksum as well (#1003) --- 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) - // } } }