diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2024-11-09 11:32:08 -0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-11-09 11:32:08 -0800 |
| commit | 72b14a451ec44ad700f3e4b35103f7fd2676d8ef (patch) | |
| tree | 6d820c8be32149e794ea5385dacb431536d6e3e6 /weed/shell/command_ec_encode.go | |
| parent | 3400962877fc05b944f04390583e072eeec2af05 (diff) | |
| download | seaweedfs-72b14a451ec44ad700f3e4b35103f7fd2676d8ef.tar.xz seaweedfs-72b14a451ec44ad700f3e4b35103f7fd2676d8ef.zip | |
delete aborted ec shards from both source and target servers (#6221)
fix https://github.com/seaweedfs/seaweedfs/issues/6205#issuecomment-2465004586
Diffstat (limited to 'weed/shell/command_ec_encode.go')
| -rw-r--r-- | weed/shell/command_ec_encode.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/shell/command_ec_encode.go b/weed/shell/command_ec_encode.go index 072a95a2c..6edd57f45 100644 --- a/weed/shell/command_ec_encode.go +++ b/weed/shell/command_ec_encode.go @@ -237,7 +237,10 @@ func parallelCopyEcShardsFromSource(grpcDialOption grpc.DialOption, targetServer fmt.Printf("unmount aborted shards %d.%v on %s: %v\n", volumeId, allocatedEcShardIds, server.info.Id, err) } if err := sourceServerDeleteEcShards(grpcDialOption, collection, volumeId, pb.NewServerAddressFromDataNode(server.info), allocatedEcShardIds); err != nil { - fmt.Printf("remove aborted shards %d.%v on %s: %v\n", volumeId, allocatedEcShardIds, server.info.Id, err) + fmt.Printf("remove aborted shards %d.%v on target server %s: %v\n", volumeId, allocatedEcShardIds, server.info.Id, err) + } + if err := sourceServerDeleteEcShards(grpcDialOption, collection, volumeId, existingLocation.ServerAddress(), allocatedEcShardIds); err != nil { + fmt.Printf("remove aborted shards %d.%v on existing server %s: %v\n", volumeId, allocatedEcShardIds, existingLocation.ServerAddress(), err) } } |