|
@ -303,7 +303,7 @@ func (s *Store) doReadRemoteEcShardInterval(sourceDataNode string, needleId type |
|
|
break |
|
|
break |
|
|
} |
|
|
} |
|
|
if receiveErr != nil { |
|
|
if receiveErr != nil { |
|
|
return fmt.Errorf("receiving ec shard %d.%d from %s: %v", vid, shardId, sourceDataNode, err) |
|
|
|
|
|
|
|
|
return fmt.Errorf("receiving ec shard %d.%d from %s: %v", vid, shardId, sourceDataNode, receiveErr) |
|
|
} |
|
|
} |
|
|
if resp.IsDeleted { |
|
|
if resp.IsDeleted { |
|
|
is_deleted = true |
|
|
is_deleted = true |
|
|