gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 10:06:14 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(data): Fix data log problem. #1000202936

Browse Source 
Signed-off-by: zhumingze <zhumingze@oppo.com>
This commit is contained in:
zhumingze 2025-06-30 16:44:33 +08:00 committed by 曾雪伟
parent b8fccc1d86
commit 423060acef
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
datanode/partition.go
View File

@ -1051,6 +1051,10 @@ func (dp *DataPartition) LaunchRepair(extentType uint8) {
return
}
if err := dp.updateReplicas(false); err != nil {
if strings.Contains(err.Error(), proto.ErrDataPartitionNotExists.Error()) {
log.LogWarnf("action[LaunchRepair] partition(%v) err(%v).", dp.partitionID, err)
return
}
log.LogErrorf("action[LaunchRepair] partition(%v) err(%v).", dp.partitionID, err)
return
}

2
sdk/master/client.go
View File

@ -204,7 +204,7 @@ func (c *MasterClient) serveRequest(r *request) (repsData []byte, err error) {
return nil, fmt.Errorf("unmarshal response body err:%v", err)
}
if body.Code != proto.ErrCodeSuccess {
log.LogWarnf("serveRequest: code[%v], msg[%v], data[%v] ", body.Code, body.Msg, body.Data)
log.LogWarnf("serveRequest: code[%v], msg[%v], data[%v] ", body.Code, body.Msg, string(body.Data))
if body.Code == proto.ErrCodeInternalError && len(body.Msg) != 0 {
return nil, errors.New(body.Msg)
} else if CliPrint && body.Code == proto.ErrCodeParamError && len(body.Msg) != 0 {