You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by dh...@apache.org on 2021/07/29 18:18:09 UTC
[arrow-datafusion] branch master updated: fix: Fix clippy lints
introduced in 1.54 (#794)
This is an automated email from the ASF dual-hosted git repository.
dheres 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 7dde5b1 fix: Fix clippy lints introduced in 1.54 (#794)
7dde5b1 is described below
commit 7dde5b13801dce6450bac10bd385c323a5f1cbff
Author: Andrew Lamb <an...@nerdnetworks.org>
AuthorDate: Thu Jul 29 14:18:02 2021 -0400
fix: Fix clippy lints introduced in 1.54 (#794)
---
ballista/rust/client/src/context.rs | 4 ++--
ballista/rust/core/src/serde/physical_plan/mod.rs | 2 +-
ballista/rust/scheduler/src/state/mod.rs | 2 +-
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/ballista/rust/client/src/context.rs b/ballista/rust/client/src/context.rs
index 16a90b2..162cd68 100644
--- a/ballista/rust/client/src/context.rs
+++ b/ballista/rust/client/src/context.rs
@@ -133,7 +133,7 @@ impl BallistaContext {
let mut ctx = create_datafusion_context(
&guard.scheduler_host,
guard.scheduler_port,
- &guard.config(),
+ guard.config(),
);
let df = ctx.read_parquet(path.to_str().unwrap())?;
Ok(df)
@@ -155,7 +155,7 @@ impl BallistaContext {
let mut ctx = create_datafusion_context(
&guard.scheduler_host,
guard.scheduler_port,
- &guard.config(),
+ guard.config(),
);
let df = ctx.read_csv(path.to_str().unwrap(), options)?;
Ok(df)
diff --git a/ballista/rust/core/src/serde/physical_plan/mod.rs b/ballista/rust/core/src/serde/physical_plan/mod.rs
index f544859..4bf013a 100644
--- a/ballista/rust/core/src/serde/physical_plan/mod.rs
+++ b/ballista/rust/core/src/serde/physical_plan/mod.rs
@@ -105,7 +105,7 @@ mod roundtrip_tests {
Arc::new(EmptyExec::new(false, schema_left.clone())),
Arc::new(EmptyExec::new(false, schema_right.clone())),
on.clone(),
- &join_type,
+ join_type,
*partition_mode,
)?))?;
}
diff --git a/ballista/rust/scheduler/src/state/mod.rs b/ballista/rust/scheduler/src/state/mod.rs
index 0bbab8c..865b44b 100644
--- a/ballista/rust/scheduler/src/state/mod.rs
+++ b/ballista/rust/scheduler/src/state/mod.rs
@@ -316,7 +316,7 @@ impl SchedulerState {
))
.unwrap();
let task_is_dead = self
- .reschedule_dead_task(&referenced_task, &executors)
+ .reschedule_dead_task(referenced_task, &executors)
.await?;
if task_is_dead {
continue 'tasks;