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

fix(data): Change the log level of dp not exist in repl_protocol from error to warn. #1000157333

Browse Source 
Signed-off-by: zhumingze <zhumingze@oppo.com>
This commit is contained in:
zhumingze 2025-06-04 11:32:05 +08:00 committed by zhumingze1108
parent 1ca22fc68c
commit cadef3627a
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
datanode/repl/repl_protocol.go
View File

@ -437,7 +437,8 @@ func (rp *ReplProtocol) writeResponse(reply *Packet) {
} else if (reply.ResultCode == proto.OpTryOtherAddr && reply.Opcode == proto.OpWrite) ||
reply.Opcode == proto.OpReadTinyDeleteRecord ||
(reply.Opcode == proto.OpWrite && proto.IsTinyExtentType(reply.ExtentType) && strings.Contains(err.Error(), "GetAvailableTinyExtent error no available extent")) ||
(reply.Opcode == proto.OpWrite && reply.ResultCode == proto.OpLimitedIoErr && strings.Contains(err.Error(), ActionReceiveFromFollower)) {
(reply.Opcode == proto.OpWrite && reply.ResultCode == proto.OpLimitedIoErr && strings.Contains(err.Error(), ActionReceiveFromFollower)) ||
strings.Contains(err.Error(), proto.ErrDataPartitionNotExists.Error()) {
log.LogWarnf(err.Error())
} else {
log.LogErrorf(err.Error())

2
datanode/wrap_prepare.go
View File

@ -94,7 +94,7 @@ func (s *DataNode) checkPartition(p *repl.Packet) (err error) {
dp := s.space.Partition(p.PartitionID)
if dp == nil {
// err = proto.ErrDataPartitionNotExists
err = fmt.Errorf("data partition not exists %v", p.PartitionID)
err = fmt.Errorf("%v %v", proto.ErrDataPartitionNotExists.Error(), p.PartitionID)
return
}
p.Object = dp