diff --git a/weed/storage/volume_stream_write.go b/weed/storage/volume_stream_write.go index f619de30b..955875aa2 100644 --- a/weed/storage/volume_stream_write.go +++ b/weed/storage/volume_stream_write.go @@ -48,8 +48,6 @@ func (v *Volume) StreamWrite(n *needle.Needle, data io.Reader, dataSize uint32) // data checksum util.Uint32toBytes(header[0:needle.NeedleChecksumSize], crcWriter.Sum()) - df.Write(header[0:needle.NeedleChecksumSize]) - // write timestamp, padding n.AppendAtNs = uint64(time.Now().UnixNano()) util.Uint64toBytes(header[needle.NeedleChecksumSize:needle.NeedleChecksumSize+TimestampSize], n.AppendAtNs)