From 1243a115f698f7d2c2b06a2ae2e444bdd95d62be Mon Sep 17 00:00:00 2001
From: Mitsuhiro Tanda <mitsuhiro.tanda@gmail.com>
Date: Wed, 15 May 2024 15:14:09 +0900
Subject: [PATCH] fix, refer new column name

---
 collector/slave_status.go | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/collector/slave_status.go b/collector/slave_status.go
index 7aa0da964..b7984657f 100644
--- a/collector/slave_status.go
+++ b/collector/slave_status.go
@@ -113,7 +113,13 @@ func (ScrapeSlaveStatus) Scrape(ctx context.Context, db *sql.DB, ch chan<- prome
 		}
 
 		masterUUID := columnValue(scanArgs, slaveCols, "Master_UUID")
+		if masterUUID == "" {
+			masterUUID = columnValue(scanArgs, slaveCols, "Source_UUID")
+		}
 		masterHost := columnValue(scanArgs, slaveCols, "Master_Host")
+		if masterHost == "" {
+			masterHost = columnValue(scanArgs, slaveCols, "Source_Host")
+		}
 		channelName := columnValue(scanArgs, slaveCols, "Channel_Name")       // MySQL & Percona
 		connectionName := columnValue(scanArgs, slaveCols, "Connection_name") // MariaDB