fix clippy

Author: zhuqi-lucas

Cargo.lock

@@ -22,7 +22,6 @@ use std::fmt;
 use std::fmt::{Debug, Formatter};
 use std::sync::Arc;
 
-use datafusion_physical_expr::equivalence::ProjectionMapping;
 use datafusion_physical_plan::execution_plan::{
     Boundedness, EmissionType, SchedulingType,
 };

datafusion/datasource/src/source.rs

@@ -945,7 +945,6 @@ fn add_hash_on_top(
 ///
 /// # Returns
 ///
-
 /// Updated node with an execution plan, where desired single
 /// distribution is satisfied by adding [`SortPreservingMergeExec`].
 fn add_merge_on_top(

datafusion/physical-optimizer/src/enforce_distribution.rs

@@ -882,26 +882,6 @@ impl ExecutionPlan for HashJoinExec {
         }))
     }
 
-    fn reset_state(self: Arc<Self>) -> Result<Arc<dyn ExecutionPlan>> {
-        // Reset the left_fut to allow re-execution
-        Ok(Arc::new(HashJoinExec {
-            left: Arc::clone(&self.left),
-            right: Arc::clone(&self.right),
-            on: self.on.clone(),
-            filter: self.filter.clone(),
-            join_type: self.join_type,
-            join_schema: Arc::clone(&self.join_schema),
-            left_fut: OnceAsync::default(),
-            random_state: self.random_state.clone(),
-            mode: self.mode,
-            metrics: ExecutionPlanMetricsSet::new(),
-            projection: self.projection.clone(),
-            column_indices: self.column_indices.clone(),
-            null_equality: self.null_equality,
-            cache: self.cache.clone(),
-        }))
-    }
-
     fn execute(
         &self,
         partition: usize,

datafusion/physical-plan/src/joins/hash_join/exec.rs

@@ -144,7 +144,7 @@ fn roundtrip_test_and_return(
         protobuf::PhysicalPlanNode::try_from_physical_plan(exec_plan.clone(), codec)
             .expect("to proto");
     let runtime = ctx.runtime_env();
-    let mut result_exec_plan: Arc<dyn ExecutionPlan> = proto
+    let result_exec_plan: Arc<dyn ExecutionPlan> = proto
         .try_into_physical_plan(ctx, runtime.deref(), codec)
         .expect("from proto");