From 474dc7738af6430c4ca769ec51517e168955ebb3 Mon Sep 17 00:00:00 2001 From: hillium Date: Tue, 21 Mar 2023 15:13:40 +0800 Subject: [PATCH] remove LastCheckpoint metric after losing ownership Signed-off-by: hillium --- br/pkg/streamhelper/advancer_daemon.go | 1 + 1 file changed, 1 insertion(+) diff --git a/br/pkg/streamhelper/advancer_daemon.go b/br/pkg/streamhelper/advancer_daemon.go index 4e3b68eb3fbf5..c49addc8ad186 100644 --- a/br/pkg/streamhelper/advancer_daemon.go +++ b/br/pkg/streamhelper/advancer_daemon.go @@ -48,6 +48,7 @@ func (c *CheckpointAdvancer) Name() string { func (c *CheckpointAdvancer) onStop() { metrics.AdvancerOwner.Set(0.0) + metrics.LastCheckpoint.Reset() c.stopSubscriber() }