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 index 68acc751429e..64965d47d86d 100644 --- 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(); }