File tree Expand file tree Collapse file tree 1 file changed +1
-7
lines changed
native/core/src/execution Expand file tree Collapse file tree 1 file changed +1
-7
lines changed Original file line number Diff line number Diff line change @@ -1328,13 +1328,7 @@ impl PhysicalPlanner {
13281328 // SortExec fails in some cases if we do not unpack dictionary-encoded arrays, and
13291329 // it would be more efficient if we could avoid that.
13301330 // https://github.com/apache/datafusion-comet/issues/963
1331-
1332- // TODO optimize this so that we only add the CopyExec if needed
1333- // https://github.com/apache/datafusion-comet/issues/2131
1334- let child_copied = Arc :: new ( CopyExec :: new (
1335- Arc :: clone ( & child. native_plan ) ,
1336- CopyMode :: UnpackOrDeepCopy ,
1337- ) ) ;
1331+ let child_copied = Self :: wrap_in_copy_exec ( Arc :: clone ( & child. native_plan ) ) ;
13381332
13391333 let mut sort_exec: Arc < dyn ExecutionPlan > = Arc :: new (
13401334 SortExec :: new ( LexOrdering :: new ( exprs?) . unwrap ( ) , Arc :: clone ( & child_copied) )
You can’t perform that action at this time.
0 commit comments