add default value when reading needle version

4 months ago · 748bf5e4d3
1 changed files with 3 additions and 0 deletions
--- 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