You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2024/04/01 16:59:32 UTC
(ignite-3) 01/02: Fix test
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 <an...@gmail.com>
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")))