diff --git a/datafusion/core/src/physical_plan/repartition/mod.rs b/datafusion/core/src/physical_plan/repartition/mod.rs
index 8567c57778c48..ec1d092ae7acb 100644
--- a/datafusion/core/src/physical_plan/repartition/mod.rs
+++ b/datafusion/core/src/physical_plan/repartition/mod.rs
@@ -46,7 +46,7 @@ use super::{RecordBatchStream, SendableRecordBatchStream};
 use crate::execution::context::TaskContext;
 use datafusion_physical_expr::PhysicalExpr;
 use futures::stream::Stream;
-use futures::{Future, FutureExt, StreamExt};
+use futures::{FutureExt, StreamExt};
 use hashbrown::HashMap;
 use parking_lot::Mutex;
 use tokio::task::JoinHandle;
@@ -224,14 +224,6 @@ impl BatchPartitioner {
     }
 }
 
-trait PartitiontFun {
-    type Fut<'a>: Future<Output = Result<()>>
-    where
-        Self: 'a;
-
-    fn c(&mut self, partition: usize, batch: RecordBatch) -> Self::Fut<'_>;
-}
-
 /// The repartition operator maps N input partitions to M output partitions based on a
 /// partitioning scheme. No guarantees are made about the order of the resulting partitions.
 #[derive(Debug)]