diff --git a/br/pkg/streamhelper/advancer_daemon.go b/br/pkg/streamhelper/advancer_daemon.go index c202a1b44f820..889c988886fa4 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() }