Upgrade crates

apache · Nov 16, 2023 · c8a6427 · c8a6427
1 parent 8d0ddc2
commit c8a6427
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 6 deletions.
diff --git a/ballista/core/Cargo.toml b/ballista/core/Cargo.toml
@@ -57,7 +57,7 @@ datafusion-proto = { workspace = true }
 futures = "0.3"
 hashbrown = "0.14"
 
-itertools = "0.11"
+itertools = "0.12"
 libloading = "0.8.0"
 log = "0.4"
 md-5 = { version = "^0.10.0" }

diff --git a/ballista/scheduler/Cargo.toml b/ballista/scheduler/Cargo.toml
@@ -47,20 +47,20 @@ arrow-flight = { workspace = true }
 async-recursion = "1.0.0"
 async-trait = "0.1.41"
 ballista-core = { path = "../core", version = "0.11.0", features = ["s3"] }
-base64 = { version = "0.13" }
+base64 = { version = "0.21" }
 clap = { version = "3", features = ["derive", "cargo"] }
 configure_me = { workspace = true }
 dashmap = "5.4.0"
 datafusion = { workspace = true }
 datafusion-proto = { workspace = true }
-etcd-client = { version = "0.11", optional = true }
+etcd-client = { version = "0.12", optional = true }
 flatbuffers = { version = "23.5.26" }
 futures = "0.3"
 graphviz-rust = "0.6.1"
 http = "0.2"
 http-body = "0.4"
 hyper = "0.14.4"
-itertools = "0.11.0"
+itertools = "0.12.0"
 log = "0.4"
 object_store = { workspace = true }
 once_cell = { version = "1.16.0", optional = true }

diff --git a/ballista/scheduler/src/flight_sql.rs b/ballista/scheduler/src/flight_sql.rs
@@ -35,6 +35,7 @@ use arrow_flight::{
     Action, FlightData, FlightDescriptor, FlightEndpoint, FlightInfo, HandshakeRequest,
     HandshakeResponse, Location, Ticket,
 };
+use base64::Engine;
 use futures::Stream;
 use log::{debug, error, warn};
 use std::convert::TryFrom;
@@ -503,8 +504,8 @@ impl FlightSqlService for FlightSqlServiceImpl {
                 "Auth type not implemented: {authorization}"
             )))?;
         }
-        let base64 = &authorization[basic.len()..];
-        let bytes = base64::decode(base64)
+        let bytes = base64::engine::general_purpose::STANDARD
+            .decode(&authorization[basic.len()..])
             .map_err(|_| Status::invalid_argument("authorization not parsable"))?;
         let str = String::from_utf8(bytes)
             .map_err(|_| Status::invalid_argument("authorization not parsable"))?;