diff --git a/datafusion/physical-plan/src/aggregates/mod.rs b/datafusion/physical-plan/src/aggregates/mod.rs
index df4ba289b10f..8caf10acf09b 100644
--- a/datafusion/physical-plan/src/aggregates/mod.rs
+++ b/datafusion/physical-plan/src/aggregates/mod.rs
@@ -2339,12 +2339,15 @@ mod tests {
                 let b = Arc::new(Float32Array::from(vec![0.; 8192]));
                 let c = Arc::new(Int32Array::from(vec![1; 8192]));
 
-                RecordBatch::try_new(schema.clone(), vec![a, b, c]).unwrap()
+                RecordBatch::try_new(Arc::clone(&schema), vec![a, b, c]).unwrap()
             })
             .collect();
 
-        let input =
-            Arc::new(MemoryExec::try_new(&[input_batches], schema.clone(), None)?);
+        let input = Arc::new(MemoryExec::try_new(
+            &[input_batches],
+            Arc::clone(&schema),
+            None,
+        )?);
 
         let aggregate_exec = Arc::new(AggregateExec::try_new(
             AggregateMode::Partial,
diff --git a/datafusion/physical-plan/src/joins/hash_join.rs b/datafusion/physical-plan/src/joins/hash_join.rs
index 09e198199e02..2f4ee00da35f 100644
--- a/datafusion/physical-plan/src/joins/hash_join.rs
+++ b/datafusion/physical-plan/src/joins/hash_join.rs
@@ -3955,12 +3955,12 @@ mod tests {
         )];
 
         let (_, batches_null_eq) = join_collect(
-            left.clone(),
-            right.clone(),
+            Arc::clone(&left),
+            Arc::clone(&right),
             on.clone(),
             &JoinType::Inner,
             true,
-            task_ctx.clone(),
+            Arc::clone(&task_ctx),
         )
         .await?;