File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed
datafusion/physical-optimizer/src/enforce_sorting Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -34,7 +34,7 @@ use datafusion_physical_plan::execution_plan::EmissionType;
3434use datafusion_physical_plan:: repartition:: RepartitionExec ;
3535use datafusion_physical_plan:: sorts:: sort_preserving_merge:: SortPreservingMergeExec ;
3636use datafusion_physical_plan:: tree_node:: PlanContext ;
37- use datafusion_physical_plan:: { ExecutionPlan , ExecutionPlanProperties } ;
37+ use datafusion_physical_plan:: ExecutionPlanProperties ;
3838
3939use itertools:: izip;
4040
@@ -205,9 +205,8 @@ pub fn plan_with_order_breaking_variants(
205205 // Replace `SortPreservingMergeExec` with a `CoalescePartitionsExec`
206206 // SPM may have `fetch`, so pass it to the `CoalescePartitionsExec`
207207 let child = Arc :: clone ( & sort_input. children [ 0 ] . plan ) ;
208- let coalesce = CoalescePartitionsExec :: new ( child)
209- . with_fetch ( plan. fetch ( ) )
210- . unwrap ( ) ;
208+ let coalesce =
209+ Arc :: new ( CoalescePartitionsExec :: new ( child) . with_fetch ( plan. fetch ( ) ) ) ;
211210 sort_input. plan = coalesce;
212211 } else {
213212 return sort_input. update_plan_from_children ( ) ;
You can’t perform that action at this time.
0 commit comments