diff --git a/crates/paimon/src/io/file_io.rs b/crates/paimon/src/io/file_io.rs index 1a4998a0..63735486 100644 --- a/crates/paimon/src/io/file_io.rs +++ b/crates/paimon/src/io/file_io.rs @@ -751,7 +751,11 @@ impl OutputFile { pub async fn writer(&self) -> crate::Result> { let (op, relative_path, cache_path) = self.resolve().await?; - let writer: Box = Box::new(op.writer(&relative_path).await?); + let writer: Box = Box::new( + op.writer_with(&relative_path) + .chunk(8 * 1024 * 1024) + .await?, + ); let Some(cache) = &self.cache else { return Ok(writer); }; @@ -766,7 +770,8 @@ impl OutputFile { pub(crate) async fn async_writer(&self) -> crate::Result> { let (op, relative_path, cache_path) = self.resolve().await?; let writer: Box = Box::new( - op.writer(&relative_path) + op.writer_with(&relative_path) + .chunk(8 * 1024 * 1024) .await? .into_futures_async_write() .compat_write(),