fix logical merge conflict

apache · May 27, 2021 · 7d3dbc5 · 7d3dbc5
1 parent 29c767b
commit 7d3dbc5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/datafusion/src/physical_plan/sort_preserving_merge.rs b/datafusion/src/physical_plan/sort_preserving_merge.rs
@@ -633,7 +633,8 @@ mod tests {
         input: Arc<dyn ExecutionPlan>,
         sort: Vec<PhysicalSortExpr>,
     ) -> RecordBatch {
-        let sort_exec = Arc::new(SortExec::try_new(sort.clone(), input).unwrap());
+        let sort_exec =
+            Arc::new(SortExec::new_with_partitioning(sort.clone(), input, true));
         sorted_merge(sort_exec, sort).await
     }