lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-11-09 03:44:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update command_fs_merge_volumes.go (#6406)

Browse Source
This commit is contained in:
Brad Murray
2025-01-02 11:57:26 -05:00
committed by GitHub
parent 56123d1b03
commit bc3640ee64
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
weed/shell/command_fs_merge_volumes.go
View File

@@ -112,15 +112,15 @@ func (c *commandFsMergeVolumes) Do(args []string, commandEnv *CommandEnv, writer
return return
} }
for _, chunk := range entry.Chunks { for _, chunk := range entry.Chunks {
if chunk.IsChunkManifest {
fmt.Printf("Change volume id for large file is not implemented yet: %s/%s\n", parentPath, entry.Name)
continue
}
chunkVolumeId := needle.VolumeId(chunk.Fid.VolumeId) chunkVolumeId := needle.VolumeId(chunk.Fid.VolumeId)
toVolumeId, found := plan[chunkVolumeId] toVolumeId, found := plan[chunkVolumeId]
if !found { if !found {
continue continue
} }
if chunk.IsChunkManifest {
fmt.Printf("Change volume id for large file is not implemented yet: %s/%s\n", parentPath, entry.Name)
continue
}
path := parentPath.Child(entry.Name) path := parentPath.Child(entry.Name)
fmt.Printf("move %s(%s)\n", path, chunk.GetFileIdString()) fmt.Printf("move %s(%s)\n", path, chunk.GetFileIdString())