diff --git a/pkg/experiment/metastore/metastore.go b/pkg/experiment/metastore/metastore.go
index a0f0a7a6a6..7abd92afa2 100644
--- a/pkg/experiment/metastore/metastore.go
+++ b/pkg/experiment/metastore/metastore.go
@@ -273,18 +273,6 @@ func (m *Metastore) initRaft() (err error) {
 	return nil
 }
 
-func (m *Metastore) OnLeaderChange(state raft.RaftState) {
-	if state == raft.Leader {
-		m.dlq.Start()
-		m.placementMgr.Start()
-		m.blockCleaner.Start()
-	} else {
-		m.dlq.Stop()
-		m.placementMgr.Stop()
-		m.blockCleaner.Stop()
-	}
-}
-
 func (m *Metastore) openRaftStore() (hasState bool, err error) {
 	if err = m.createRaftDirs(); err != nil {
 		return false, err