diff --git a/core/src/services/aliyun_drive/writer.rs b/core/src/services/aliyun_drive/writer.rs index 9873eaa73c0..35afaaade7f 100644 --- a/core/src/services/aliyun_drive/writer.rs +++ b/core/src/services/aliyun_drive/writer.rs @@ -115,10 +115,11 @@ impl oio::Write for AliyunDriveWriter { async fn close(&mut self) -> Result { let (Some(upload_id), Some(file_id)) = (self.upload_id.as_ref(), self.file_id.as_ref()) else { - return Ok(Metadata::default()); + return Ok(Metadata::default().with_content_length(self.write_bytes_count)); }; + self.core.complete(file_id, upload_id).await?; - Ok(Metadata::default()) + Ok(Metadata::default().with_content_length(self.write_bytes_count)) } async fn abort(&mut self) -> Result<()> {