aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-09-06 12:44:02 -0700
committerChris Lu <chris.lu@gmail.com>2020-09-06 12:44:02 -0700
commit05034aade5da8525b6067dece4a738cc664dabc4 (patch)
treedb7b2e167b36694b83153b5a9977ce2983856eb4
parent432fe3d926044f81ec445136c13774684237266c (diff)
downloadseaweedfs-05034aade5da8525b6067dece4a738cc664dabc4.tar.xz
seaweedfs-05034aade5da8525b6067dece4a738cc664dabc4.zip
printout over replicated locations
-rw-r--r--weed/shell/command_volume_fix_replication.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/weed/shell/command_volume_fix_replication.go b/weed/shell/command_volume_fix_replication.go
index e17f35c67..59f4bff10 100644
--- a/weed/shell/command_volume_fix_replication.go
+++ b/weed/shell/command_volume_fix_replication.go
@@ -85,6 +85,8 @@ func (c *commandVolumeFixReplication) Do(args []string, commandEnv *CommandEnv,
replicaPlacement, _ := super_block.NewReplicaPlacementFromByte(byte(volumeInfo.ReplicaPlacement))
if replicaPlacement.GetCopyCount() > len(locations) {
underReplicatedVolumeLocations[vid] = locations
+ } else if replicaPlacement.GetCopyCount() < len(locations) {
+ fmt.Fprintf(writer, "volume %d replication %s, but over repliacated:%+v\n", volumeInfo.Id, replicaPlacement, locations)
}
}