diff --git a/native/core/src/execution/datafusion/planner.rs b/native/core/src/execution/datafusion/planner.rs
index 9b237e5e3..79aaf0c0d 100644
--- a/native/core/src/execution/datafusion/planner.rs
+++ b/native/core/src/execution/datafusion/planner.rs
@@ -1070,8 +1070,6 @@ impl PhysicalPlanner {
                 let partitioning = self
                     .create_partitioning(writer.partitioning.as_ref().unwrap(), child.schema())?;
 
-
-
                 let shuffle_writer = Arc::new(ShuffleWriterExec::try_new(
                     Arc::clone(&child.native_plan),
                     partitioning,
@@ -1081,11 +1079,10 @@ impl PhysicalPlanner {
 
                 Ok((
                     scans,
-                    Arc::new(SparkPlan::new_with_additional(
+                    Arc::new(SparkPlan::new(
                         spark_plan.plan_id,
                         shuffle_writer,
                         vec![Arc::clone(&child)],
-                        vec![Arc::clone(&child.native_plan)]
                     )),
                 ))
             }