updateMasterToNewOneForcefully

OpenAtomFoundation · Jul 8, 2024 · 8285283 · 8285283
1 parent 12090e4
commit 8285283
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/codis/pkg/topom/topom_group.go b/codis/pkg/topom/topom_group.go
@@ -391,8 +391,8 @@ func (s *Topom) tryFixReplicationRelationship(group *models.Group, groupServer *
 			return nil
 		}
 
-		// current server is slave, execute the command `slaveof [new master ip] [new master port]`
-		if err = updateMasterToNewOne(groupServer.Addr, curMasterAddr, s.config.ProductAuth); err != nil {
+		// current server is slave, execute the command `slaveof [new master ip] [new master port] force`
+		if err = updateMasterToNewOneForcefully(groupServer.Addr, curMasterAddr, s.config.ProductAuth); err != nil {
 			return err
 		}
 	}