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

ygcyao · Nov 19, 2024 · e98cd78 · e98cd78
1 parent 5d232b4
commit e98cd78
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
 }