Remove redundant case

FIXED_PASSTHROUGH_DISTRIBUTION is not really a node partitioning. It's a local partitioning type
trinodb · Nov 29, 2022 · 0e652c9 · 0e652c9
1 parent eddaab2
commit 0e652c9
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/core/trino-main/src/main/java/io/trino/sql/planner/optimizations/PropertyDerivations.java b/core/trino-main/src/main/java/io/trino/sql/planner/optimizations/PropertyDerivations.java
@@ -102,7 +102,6 @@
 import static io.trino.spi.predicate.TupleDomain.extractFixedValues;
 import static io.trino.sql.planner.SystemPartitioningHandle.ARBITRARY_DISTRIBUTION;
 import static io.trino.sql.planner.SystemPartitioningHandle.COORDINATOR_DISTRIBUTION;
-import static io.trino.sql.planner.SystemPartitioningHandle.FIXED_PASSTHROUGH_DISTRIBUTION;
 import static io.trino.sql.planner.SystemPartitioningHandle.SINGLE_DISTRIBUTION;
 import static io.trino.sql.planner.optimizations.ActualProperties.Global.arbitraryPartition;
 import static io.trino.sql.planner.optimizations.ActualProperties.Global.coordinatorSingleStreamPartition;
@@ -689,13 +688,6 @@ else if (inputProperties.stream().anyMatch(ActualProperties::isSingleNode)) {
                             // only gathering local exchange preserves single stream property
                             node.getType() == GATHER ? Optional.of(ImmutableList.of()) : Optional.empty()));
                 }
-                else if (node.getOrderingScheme().isPresent() && node.getType() == GATHER) {
-                    // Local merging exchange uses passthrough distribution
-                    builder.global(partitionedOn(
-                            FIXED_PASSTHROUGH_DISTRIBUTION,
-                            ImmutableList.of(),
-                            Optional.of(ImmutableList.of())));
-                }
 
                 return builder.build();
             }