You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by al...@apache.org on 2021/08/02 19:45:30 UTC
[arrow-datafusion] branch master updated: Update dependencies:
prost to 0.8 and tonic to 0.5 (#818)
This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
The following commit(s) were added to refs/heads/master by this push:
new e18d79f Update dependencies: prost to 0.8 and tonic to 0.5 (#818)
e18d79f is described below
commit e18d79f7c2cae44de28af2b643c0e45085212f48
Author: Andrew Lamb <an...@nerdnetworks.org>
AuthorDate: Mon Aug 2 15:45:23 2021 -0400
Update dependencies: prost to 0.8 and tonic to 0.5 (#818)
---
ballista-examples/Cargo.toml | 4 ++--
ballista/rust/core/Cargo.toml | 6 +++---
ballista/rust/executor/Cargo.toml | 2 +-
ballista/rust/executor/src/flight_service.rs | 4 ++--
ballista/rust/scheduler/Cargo.toml | 6 +++---
datafusion-examples/Cargo.toml | 4 ++--
6 files changed, 13 insertions(+), 13 deletions(-)
diff --git a/ballista-examples/Cargo.toml b/ballista-examples/Cargo.toml
index b7d4022..dbcfad4 100644
--- a/ballista-examples/Cargo.toml
+++ b/ballista-examples/Cargo.toml
@@ -31,8 +31,8 @@ publish = false
arrow-flight = { version = "5.0" }
datafusion = { path = "../datafusion" }
ballista = { path = "../ballista/rust/client" }
-prost = "0.7"
-tonic = "0.4"
+prost = "0.8"
+tonic = "0.5"
tokio = { version = "1.0", features = ["macros", "rt", "rt-multi-thread", "sync"] }
futures = "0.3"
num_cpus = "1.13.0"
diff --git a/ballista/rust/core/Cargo.toml b/ballista/rust/core/Cargo.toml
index ce72d2f..2495343 100644
--- a/ballista/rust/core/Cargo.toml
+++ b/ballista/rust/core/Cargo.toml
@@ -35,11 +35,11 @@ async-trait = "0.1.36"
futures = "0.3"
hashbrown = "0.11"
log = "0.4"
-prost = "0.7"
+prost = "0.8"
serde = {version = "1", features = ["derive"]}
sqlparser = "0.9.0"
tokio = "1.0"
-tonic = "0.4"
+tonic = "0.5"
uuid = { version = "0.8", features = ["v4"] }
arrow-flight = { version = "5.0" }
@@ -50,4 +50,4 @@ datafusion = { path = "../../../datafusion" }
tempfile = "3"
[build-dependencies]
-tonic-build = { version = "0.4" }
+tonic-build = { version = "0.5" }
diff --git a/ballista/rust/executor/Cargo.toml b/ballista/rust/executor/Cargo.toml
index 428a5bb..5d6ecb9 100644
--- a/ballista/rust/executor/Cargo.toml
+++ b/ballista/rust/executor/Cargo.toml
@@ -40,7 +40,7 @@ snmalloc-rs = {version = "0.2", features= ["cache-friendly"], optional = true}
tempfile = "3"
tokio = { version = "1.0", features = ["macros", "rt", "rt-multi-thread"] }
tokio-stream = { version = "0.1", features = ["net"] }
-tonic = "0.4"
+tonic = "0.5"
uuid = { version = "0.8", features = ["v4"] }
arrow = { version = "5.0" }
diff --git a/ballista/rust/executor/src/flight_service.rs b/ballista/rust/executor/src/flight_service.rs
index 73dd1a9..27b1a33 100644
--- a/ballista/rust/executor/src/flight_service.rs
+++ b/ballista/rust/executor/src/flight_service.rs
@@ -218,8 +218,8 @@ where
let batch_flight_data: Vec<_> = batch
.map(|b| create_flight_iter(&b, &options).collect())
.map_err(|e| from_arrow_err(&e))?;
- for batch in &batch_flight_data {
- send_response(&tx, batch.clone()).await?;
+ for batch in batch_flight_data.into_iter() {
+ send_response(&tx, batch).await?;
}
}
info!("FetchPartition streamed {} rows", row_count);
diff --git a/ballista/rust/scheduler/Cargo.toml b/ballista/rust/scheduler/Cargo.toml
index 9bca8d9..382f7c6 100644
--- a/ballista/rust/scheduler/Cargo.toml
+++ b/ballista/rust/scheduler/Cargo.toml
@@ -43,13 +43,13 @@ http-body = "0.4"
hyper = "0.14.4"
log = "0.4"
parse_arg = "0.1.3"
-prost = "0.7"
+prost = "0.8"
rand = "0.8"
serde = {version = "1", features = ["derive"]}
sled_package = { package = "sled", version = "0.34", optional = true }
tokio = { version = "1.0", features = ["full"] }
tokio-stream = { version = "0.1", features = ["net"], optional = true }
-tonic = "0.4"
+tonic = "0.5"
tower = { version = "0.4" }
warp = "0.3"
@@ -61,7 +61,7 @@ uuid = { version = "0.8", features = ["v4"] }
[build-dependencies]
configure_me_codegen = "0.4.0"
-tonic-build = { version = "0.4" }
+tonic-build = { version = "0.5" }
[package.metadata.configure_me.bin]
scheduler = "scheduler_config_spec.toml"
diff --git a/datafusion-examples/Cargo.toml b/datafusion-examples/Cargo.toml
index 35aa376..3ddcdf4 100644
--- a/datafusion-examples/Cargo.toml
+++ b/datafusion-examples/Cargo.toml
@@ -31,8 +31,8 @@ publish = false
[dev-dependencies]
arrow-flight = { version = "5.0" }
datafusion = { path = "../datafusion" }
-prost = "0.7"
-tonic = "0.4"
+prost = "0.8"
+tonic = "0.5"
tokio = { version = "1.0", features = ["macros", "rt", "rt-multi-thread", "sync"] }
futures = "0.3"
num_cpus = "1.13.0"