ruchirK commented on code in PR #18673:
URL: https://github.com/apache/datafusion/pull/18673#discussion_r2525472176
##########
datafusion/physical-plan/src/repartition/mod.rs:
##########
@@ -1178,7 +1180,8 @@ impl RepartitionExec {
/// Return the sort expressions that are used to merge
fn sort_exprs(&self) -> Option<&LexOrdering> {
- if self.preserve_order {
+ if self.preserve_order ||
self.input.output_partitioning().partition_count() <= 1
+ {
Review Comment:
Thank you for the catch! That was definitely not intended and I will remove.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
