diff --git a/fs/operations/multithread.go b/fs/operations/multithread.go index 4f27d6b43..d6753eb14 100644 --- a/fs/operations/multithread.go +++ b/fs/operations/multithread.go @@ -312,8 +312,8 @@ func (w *writerAtChunkWriter) WriteChunk(ctx context.Context, chunkNumber int, r // if we were buffering, flush to disk switch w := writer.(type) { case *bufio.Writer: - er2 := w.Flush() - if er2 != nil { + err = w.Flush() + if err != nil { return -1, fmt.Errorf("multi-thread copy: flush failed: %w", err) } }