We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4bd7aca commit 57a3c63Copy full SHA for 57a3c63
datafusion/physical-plan/src/coalesce_partitions.rs
@@ -64,8 +64,10 @@ impl CoalescePartitionsExec {
64
fn compute_properties(input: &Arc<dyn ExecutionPlan>) -> PlanProperties {
65
// Coalescing partitions loses existing orderings:
66
let mut eq_properties = input.equivalence_properties().clone();
67
- eq_properties.clear_orderings();
68
- eq_properties.clear_per_partition_constants();
+ if input.output_partitioning().partition_count() > 1 {
+ eq_properties.clear_orderings();
69
+ eq_properties.clear_per_partition_constants();
70
+ }
71
PlanProperties::new(
72
eq_properties, // Equivalence Properties
73
Partitioning::UnknownPartitioning(1), // Output Partitioning
0 commit comments