nil check.

artie-labs · Dec 18, 2024 · 3328319 · 3328319
1 parent 558e987
commit 3328319
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/lib/mysql/gtid.go b/lib/mysql/gtid.go
@@ -8,6 +8,11 @@ import (
 )
 
 func ShouldProcessRow(set mysql.GTIDSet, currentGTID string) (bool, error) {
+	if set == nil {
+		// We have not seen any GTIDs yet, so we should process this one.
+		return true, nil
+	}
+
 	gtidSet, ok := set.(*mysql.MysqlGTIDSet)
 	if !ok {
 		return false, fmt.Errorf("unsupported GTID set type: %T", set)