owner(cdc): clean up metrics when owner resigns (pingcap#4998)

close pingcap#4774
liuzix · Apr 24, 2022 · 235bbc8 · 235bbc8
1 parent 57f85ed
commit 235bbc8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/cdc/owner/owner.go b/cdc/owner/owner.go
@@ -251,6 +251,7 @@ func (o *Owner) WriteDebugInfo(w io.Writer) {
 // AsyncStop stops the owner asynchronously
 func (o *Owner) AsyncStop() {
 	atomic.StoreInt32(&o.closed, 1)
+	o.cleanStaleMetrics()
 }
 
 func (o *Owner) cleanUpChangefeed(state *orchestrator.ChangefeedReactorState) {