fix: Fix clippy lints introduced in 1.54 (#794)

apache · Jul 29, 2021 · 7dde5b1 · 7dde5b1
1 parent a6baf88
commit 7dde5b1
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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
@@ -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;