diff --git a/datafusion/physical-plan/src/continuance.rs b/datafusion/physical-plan/src/continuance.rs
index 3ed2a79465f4..b4fd3ba31985 100644
--- a/datafusion/physical-plan/src/continuance.rs
+++ b/datafusion/physical-plan/src/continuance.rs
@@ -20,10 +20,6 @@
 use std::any::Any;
 use std::sync::Arc;
 
-// use crate::error::{DataFusionError, Result};
-// use crate::physical_plan::{
-//     DisplayFormatType, Distribution, ExecutionPlan, Partitioning,
-// };
 use arrow::datatypes::SchemaRef;
 use datafusion_execution::TaskContext;
 use datafusion_physical_expr::Partitioning;
@@ -39,9 +35,6 @@ use super::{
     SendableRecordBatchStream, Statistics,
 };
 use datafusion_common::{DataFusionError, Result};
-// use tokio::stream::;
-
-// use crate::exe::context::TaskContext;
 
 /// A temporary "working table" operation where the input data will be
 /// taken from the named handle during the execution and will be re-published
diff --git a/datafusion/physical-plan/src/recursive_query.rs b/datafusion/physical-plan/src/recursive_query.rs
index b1a816abf571..b3aa1c7156ec 100644
--- a/datafusion/physical-plan/src/recursive_query.rs
+++ b/datafusion/physical-plan/src/recursive_query.rs
@@ -39,7 +39,6 @@ use super::{
 use arrow::error::ArrowError;
 use tokio::sync::mpsc::{Receiver, Sender};
 
-// use crate::execution::context::TaskContext;
 use crate::{DisplayAs, DisplayFormatType, ExecutionPlan};
 
 /// Recursive query execution plan.