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

close #4774
pingcap · Mar 28, 2022 · 809ad60 · 809ad60
1 parent 4ccb350
commit 809ad60
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/cdc/owner/owner.go b/cdc/owner/owner.go
@@ -276,6 +276,7 @@ func (o *ownerImpl) Query(query *Query, done chan<- error) {
 // AsyncStop stops the owner asynchronously
 func (o *ownerImpl) AsyncStop() {
 	atomic.StoreInt32(&o.closed, 1)
+	o.cleanStaleMetrics()
 }
 
 func (o *ownerImpl) cleanUpChangefeed(state *orchestrator.ChangefeedReactorState) {