Fix close canal client panic if use Execute after mysql host down

go-mysql-org · Apr 22, 2024 · 741c00f · 741c00f
1 parent f0df38a
commit 741c00f
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/canal/canal.go b/canal/canal.go
@@ -254,8 +254,10 @@ func (c *Canal) Close() {
 	c.cancel()
 	c.syncer.Close()
 	c.connLock.Lock()
-	c.conn.Close()
-	c.conn = nil
+	if c.conn != nil {
+		c.conn.Close()
+		c.conn = nil
+	}
 	c.connLock.Unlock()
 
 	_ = c.eventHandler.OnPosSynced(nil, c.master.Position(), c.master.GTIDSet(), true)