diff --git a/ballista/rust/client/src/context.rs b/ballista/rust/client/src/context.rs index 16a90b2e27340..162cd68352ff3 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 f544859fa7b2b..4bf013aabfc5c 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 0bbab8cebf896..865b44b6e8394 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;