aboutsummaryrefslogtreecommitdiff
path: root/weed/server/volume_grpc_remote.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/server/volume_grpc_remote.go')
-rw-r--r--weed/server/volume_grpc_remote.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/server/volume_grpc_remote.go b/weed/server/volume_grpc_remote.go
index fd9db2246..5ca6619bd 100644
--- a/weed/server/volume_grpc_remote.go
+++ b/weed/server/volume_grpc_remote.go
@@ -48,7 +48,7 @@ func (vs *VolumeServer) FetchAndWriteNeedle(ctx context.Context, req *volume_ser
// copied from *Needle.prepareWriteBuffer()
n.Size = 4 + types.Size(n.DataSize) + 1
n.Checksum = needle.NewCRC(n.Data)
- if _, err = vs.store.WriteVolumeNeedle(v.Id, n, false); err != nil {
+ if _, err = vs.store.WriteVolumeNeedle(v.Id, n, true, false); err != nil {
return nil, fmt.Errorf("write needle %d size %d: %v", req.NeedleId, req.Size, err)
}