Skip to content

Commit 36ed21a

Browse files
committed
Reimplement ShuffleWriterExec using interleave_record_batch
Copy batches feed into ShuffleWriteExec Fix single partition shuffle write Write correct offsets
1 parent 89bfa1e commit 36ed21a

File tree

5 files changed

+333
-1003
lines changed

5 files changed

+333
-1003
lines changed

native/core/src/execution/planner.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1366,7 +1366,7 @@ impl PhysicalPlanner {
13661366
}?;
13671367

13681368
let shuffle_writer = Arc::new(ShuffleWriterExec::try_new(
1369-
Arc::clone(&child.native_plan),
1369+
Self::wrap_in_copy_exec(Arc::clone(&child.native_plan)),
13701370
partitioning,
13711371
codec,
13721372
writer.output_data_file.clone(),

0 commit comments

Comments
 (0)