From 05b35159b2bd112f67a0b1ea36dbf5f8d2f3d597 Mon Sep 17 00:00:00 2001 From: zhx Date: Sat, 23 May 2026 13:00:15 +0800 Subject: [PATCH] fix: clamp dashboard cdc position gap --- internal/monitor/metrics.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/internal/monitor/metrics.go b/internal/monitor/metrics.go index 355fe42..4ba77a2 100644 --- a/internal/monitor/metrics.go +++ b/internal/monitor/metrics.go @@ -138,9 +138,12 @@ func positionMap(pos mysql.Position) map[string]interface{} { } func positionGap(master mysql.Position, checkpoint mysql.Position) interface{} { - if master.Name == "" || checkpoint.Name == "" || master.Name != checkpoint.Name || master.Pos < checkpoint.Pos { + if master.Name == "" || checkpoint.Name == "" || master.Name != checkpoint.Name { return nil } + if master.Pos < checkpoint.Pos { + return uint32(0) + } return master.Pos - checkpoint.Pos }