diff --git a/core/src/services/fs/writer.rs b/core/src/services/fs/writer.rs index 79de8169bfd1..4c00a7c3ab79 100644 --- a/core/src/services/fs/writer.rs +++ b/core/src/services/fs/writer.rs @@ -68,7 +68,7 @@ impl oio::Write for FsWriter { async fn sink(&mut self, _size: u64, mut s: oio::Streamer) -> Result<()> { while let Some(bytes) = s.next().await { let b = bytes?; - self.f.write_all(&b).await.map_err(parse_io_error)?; + self.f.write(b).await.map_err(parse_io_error)?; } Ok(())