chore: bump opendal to v0.45.1 for connector/icelake (#15920)

risingwavelabs · Mar 26, 2024 · f292e7b · f292e7b
1 parent 388cae1
commit f292e7b
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 35 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/src/connector/Cargo.toml b/src/connector/Cargo.toml
@@ -82,7 +82,7 @@ mysql_common = { version = "0.31", default-features = false, features = [
 ] }
 nexmark = { version = "0.2", features = ["serde"] }
 num-bigint = "0.4"
-opendal = "0.44"
+opendal = "0.45"
 parking_lot = "0.12"
 paste = "1"
 prometheus = { version = "0.13", features = ["process"] }

diff --git a/src/connector/src/source/filesystem/opendal_source/opendal_reader.rs b/src/connector/src/source/filesystem/opendal_source/opendal_reader.rs
@@ -12,6 +12,8 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+use std::future::IntoFuture;
+
 use async_trait::async_trait;
 use futures::TryStreamExt;
 use futures_async_stream::try_stream;
@@ -126,6 +128,7 @@ impl<Src: OpendalSource> OpendalReader<Src> {
         let reader = op
             .reader_with(&object_name)
             .range(split.offset as u64..)
+            .into_future() // Unlike `rustc`, `try_stream` seems require manual `into_future`.
             .await?;
 
         let stream_reader = StreamReader::new(