Revert "save"

This reverts commit 56e3ead.
apache · Nov 26, 2024 · 36e6233 · 36e6233
1 parent 56e3ead
commit 36e6233
Showing 1 changed file with 1 addition and 4 deletions.
diff --git 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)]
                     )),
                 ))
             }