diff --git a/core/src/services/oss/backend.rs b/core/src/services/oss/backend.rs index d88f4e3a2973..dcd0a5b2b2f0 100644 --- a/core/src/services/oss/backend.rs +++ b/core/src/services/oss/backend.rs @@ -461,8 +461,6 @@ impl Accessor for OssBackend { let result: InitiateMultipartUploadResult = quick_xml::de::from_reader(bs.reader()) .map_err(new_xml_deserialize_error)?; - let _ = result.bucket; - let _ = result.key; Some(result.upload_id) } _ => return Err(parse_error(resp).await?), @@ -950,7 +948,9 @@ struct DeleteObjectsResultError { #[derive(Default, Debug, Deserialize)] #[serde(rename_all = "PascalCase")] struct InitiateMultipartUploadResult { + #[cfg(test)] bucket: String, + #[cfg(test)] key: String, upload_id: String, } diff --git a/core/src/services/oss/writer.rs b/core/src/services/oss/writer.rs index df012db2af90..ce7eb222a9cd 100644 --- a/core/src/services/oss/writer.rs +++ b/core/src/services/oss/writer.rs @@ -16,14 +16,14 @@ // under the License. use async_trait::async_trait; -use bytes::{Buf, Bytes}; +use bytes::Bytes; use http::StatusCode; +use super::backend::MultipartUploadPart; use super::backend::OssBackend; use super::error::parse_error; use crate::ops::OpWrite; use crate::raw::*; -use crate::services::oss::backend::{CompleteMultipartUploadResult, MultipartUploadPart}; use crate::*; pub struct OssWriter { @@ -128,13 +128,8 @@ impl oio::Write for OssWriter { .await?; match resp.status() { StatusCode::OK => { - let bs = resp.into_body().bytes().await?; - let result: CompleteMultipartUploadResult = - quick_xml::de::from_reader(bs.reader()).map_err(new_xml_deserialize_error)?; - let _ = result.location; - let _ = result.key; - let _ = result.bucket; - let _ = result.etag; + resp.into_body().consume().await?; + Ok(()) } _ => Err(parse_error(resp).await?),