From f5f3a2f9fd36c1f83788561ace34f897efe6da7b Mon Sep 17 00:00:00 2001
From: gmhdbjd <gmhdbjd@gmail.com>
Date: Fri, 23 Dec 2022 03:19:46 +0800
Subject: [PATCH] fix nil currGset for mariadb

---
 replication/binlogsyncer.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/replication/binlogsyncer.go b/replication/binlogsyncer.go
index 7421e102b..e68e48222 100644
--- a/replication/binlogsyncer.go
+++ b/replication/binlogsyncer.go
@@ -829,6 +829,9 @@ func (b *BinlogSyncer) parseEvent(s *BinlogStreamer, data []byte) error {
 		if b.prevGset == nil {
 			break
 		}
+		if b.currGset == nil {
+			b.currGset = b.prevGset.Clone()
+		}
 		prev := b.currGset.Clone()
 		err = b.currGset.(*MariadbGTIDSet).AddSet(&event.GTID)
 		if err != nil {