This is an automated email from the ASF dual-hosted git repository. amashenkov pushed a commit to branch ignite-21897 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 8a09204ea8a320549f70f4454de44da47a02de2d Author: amashenkov <[email protected]> AuthorDate: Mon Apr 1 16:06:39 2024 +0300 Fix test --- .../engine/planner/MapReduceSortAggregatePlannerTest.java | 13 ++++--------- 1 file changed, 4 insertions(+), 9 deletions(-) diff --git a/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/MapReduceSortAggregatePlannerTest.java b/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/MapReduceSortAggregatePlannerTest.java index 5329cccbc0..642cb903fc 100644 --- a/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/MapReduceSortAggregatePlannerTest.java +++ b/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/MapReduceSortAggregatePlannerTest.java @@ -520,13 +520,10 @@ public class MapReduceSortAggregatePlannerTest extends AbstractAggregatePlannerT Predicate<IgniteReduceSortAggregate> inputAgg = isInstanceOf(IgniteReduceSortAggregate.class) .and(hasGroupSets(IgniteReduceSortAggregate::getGroupSets, 0)) .and(hasCollation(RelCollations.of(0))) - .and(input(isInstanceOf(IgniteExchange.class) - .and(hasCollation(RelCollations.of(0))) - .and(hasDistribution(single())) - .and(input(isInstanceOf(IgniteMapSortAggregate.class) - .and(hasCollation(RelCollations.of(1))) - .and(hasGroupSets(Aggregate::getGroupSets, 1)) - )))); + .and(input(isInstanceOf(IgniteMapSortAggregate.class) + .and(hasCollation(RelCollations.of(1))) + .and(hasGroupSets(Aggregate::getGroupSets, 1)) + )); assertPlan(TestCase.CASE_24_1, nodeOrAnyChild(isInstanceOf(IgniteReduceSortAggregate.class) .and(hasNoGroupSets(IgniteReduceSortAggregate::getGroupSets)) @@ -815,8 +812,6 @@ public class MapReduceSortAggregatePlannerTest extends AbstractAggregatePlannerT assertPlan(testCase, nodeOrAnyChild(isInstanceOf(IgniteReduceSortAggregate.class) .and(input(isInstanceOf(IgniteMapSortAggregate.class) - // TODO: https://issues.apache.org/jira/browse/IGNITE-20095 - // Why can't Map be pushed down to under 'exchange'. .and(input(isInstanceOf(IgniteSort.class) .and(s -> s.collation().equals(collation)) .and(input(isTableScan("TEST")))
