diff --git a/weed/operation/tail_volume.go b/weed/operation/tail_volume.go index 3ab0c73cc..8decc2df9 100644 --- a/weed/operation/tail_volume.go +++ b/weed/operation/tail_volume.go @@ -55,6 +55,9 @@ func TailVolumeFromSource(volumeServer pb.ServerAddress, grpcDialOption grpc.Dia needleHeader := resp.NeedleHeader needleBody := resp.NeedleBody version := needle.Version(resp.Version) + if version == 0 { + version = needle.GetCurrentVersion() + } if len(needleHeader) == 0 { continue