fix(object store): do not call abort when streaming upload finish err…

…or and fix azure workload identity (#16961)

Cargo.toml

@@ -317,7 +317,7 @@ futures-timer = { git = "https://github.com/madsim-rs/futures-timer.git", rev =
 # patch: unlimit 4MB message size for grpc client
 etcd-client = { git = "https://github.com/risingwavelabs/etcd-client.git", rev = "4e84d40" }
 # todo(wcy-fdu): remove this patch fork after opendal release a new version to apply azure workload identity change.
-reqsign = { git = "https://github.com/wcy-fdu/reqsign.git", rev = "002ee2a" }
+reqsign = { git = "https://github.com/wcy-fdu/reqsign.git", rev = "c7dd668" }
 # patch to remove preserve_order from serde_json
 deno_core = { git = "https://github.com/bakjos/deno_core", rev = "9b241c6" }
 # patch to user reqwest 0.12.2

src/object_store/src/object/opendal_engine/opendal_object_store.rs

@@ -248,10 +248,7 @@ impl ObjectStore for OpendalObjectStore {
     }
 
     fn support_streaming_upload(&self) -> bool {
-        match self.engine_type {
-            EngineType::Azblob => false,
-            _ => self.op.info().native_capability().write_can_multi,
-        }
+        self.op.info().native_capability().write_can_multi
     }
 }
 
@@ -300,7 +297,10 @@ impl StreamingUploader for OpendalStreamingUploader {
         match self.writer.close().await {
             Ok(_) => (),
             Err(err) => {
-                self.writer.abort().await?;
+                // Due to a bug in OpenDAL, calling `abort()` here may trigger unreachable code and cause panic.
+                // refer to https://github.com/apache/opendal/issues/4651
+                // This will be fixed after the next bump in the opendal version.
+                // self.writer.abort().await?;
                 return Err(err.into());
             }
         };