diff options
| author | chrislu <chris.lu@gmail.com> | 2025-06-16 23:35:03 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-06-16 23:35:03 -0700 |
| commit | 748bf5e4d35f29e0c9a0201ed87e23a5fe1aca49 (patch) | |
| tree | 93a14a37f5afa7133b7919a51112718cbf61e109 /weed/operation/tail_volume.go | |
| parent | c602f53a6e7eca007319a8aab95f96e6fe0f73ae (diff) | |
| download | seaweedfs-748bf5e4d35f29e0c9a0201ed87e23a5fe1aca49.tar.xz seaweedfs-748bf5e4d35f29e0c9a0201ed87e23a5fe1aca49.zip | |
add default value when reading needle version
Diffstat (limited to 'weed/operation/tail_volume.go')
| -rw-r--r-- | weed/operation/tail_volume.go | 3 |
1 files changed, 3 insertions, 0 deletions
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 |