diff options
| author | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-05-20 13:19:35 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-05-20 13:19:35 +0500 |
| commit | 42f631f5495bfb55817dffe7d8ef678be33a7cbe (patch) | |
| tree | 466a9fed33f3ca84f359f7e38c42fd6ea1592cf6 | |
| parent | 03d1199d5f73fdb4302adddc91f5aeea350a13a7 (diff) | |
| download | seaweedfs-42f631f5495bfb55817dffe7d8ef678be33a7cbe.tar.xz seaweedfs-42f631f5495bfb55817dffe7d8ef678be33a7cbe.zip | |
fix https://github.com/chrislusf/seaweedfs/issues/2046
| -rw-r--r-- | weed/filer/stream.go | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/weed/filer/stream.go b/weed/filer/stream.go index 661a210ea..f1181740e 100644 --- a/weed/filer/stream.go +++ b/weed/filer/stream.go @@ -68,9 +68,12 @@ func StreamContent(masterClient wdclient.HasLookupFileIdFunction, w io.Writer, c func CheckAllChunkViews(chunkViews []*ChunkView, fileId2Url *map[string][]string, gErr *errgroup.Group) { for _, chunkView := range chunkViews { urlStrings := (*fileId2Url)[chunkView.FileId] - glog.V(9).Infof("Check chunk: %+v\n url: %v", chunkView, urlStrings) + glog.V(9).Infof("Check chunk: %+v\n url: %+v", chunkView, urlStrings) + if !chunkView.IsFullChunk() { + continue + } gErr.Go(func() error { - _, err := retriedFetchChunkData(urlStrings, chunkView.CipherKey, chunkView.IsGzipped, chunkView.IsFullChunk(), chunkView.Offset, int(chunkView.Size)) + _, err := retriedFetchChunkData(urlStrings, chunkView.CipherKey, chunkView.IsGzipped, false, 0, 2) return err }) } |