feat(mysql): 修改rocksdb备份的位点文件，满足dbm的规范要求 TencentBlueKing#8002

ylgeeker · Nov 18, 2024 · abc8daf · abc8daf
1 parent 6b6e150
commit abc8daf
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/dbm-services/mysql/db-tools/mysql-dbbackup/pkg/src/backupexe/dumper_physical_rocksdb.go b/dbm-services/mysql/db-tools/mysql-dbbackup/pkg/src/backupexe/dumper_physical_rocksdb.go
@@ -48,17 +48,11 @@ func (p *PhysicalRocksdbDumper) buildArgs() []string {
 		fmt.Sprintf("--port=%d", p.cfg.Public.MysqlPort),
 		fmt.Sprintf("--checkpoint_dir=%s", p.checkpointDir),
 		fmt.Sprintf("--backup_dir=%s", targetPath),
+		"--slave_info",
+		"--master_info",
 		"--stream=disabled",
 	}
 
-	if strings.ToLower(p.cfg.Public.MysqlRole) == cst.RoleSlave {
-		args = append(args, "--slave_info")
-	}
-
-	if strings.ToLower(p.cfg.Public.MysqlRole) == cst.RoleMaster {
-		args = append(args, "--master_info")
-	}
-
 	return args
 }