[FLINK-34505][table] fix aci

liuyongvs · Dec 20, 2024 · 91dd58a · 91dd58a
1 parent 94ab674
commit 91dd58a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...c/main/java/org/apache/flink/table/planner/plan/rules/logical/WindowGroupReorderRule.java b/...c/main/java/org/apache/flink/table/planner/plan/rules/logical/WindowGroupReorderRule.java
@@ -18,8 +18,6 @@
 
 package org.apache.flink.table.planner.plan.rules.logical;
 
-import org.apache.flink.shaded.guava31.com.google.common.collect.Lists;
-
 import org.apache.calcite.plan.RelOptRuleCall;
 import org.apache.calcite.plan.RelRule;
 import org.apache.calcite.rel.RelCollation;
@@ -78,7 +76,9 @@ public void onMatch(RelOptRuleCall call) {
                     }
                 });
 
-        if (!sequenceGroups.equals(oldGroups) && !Lists.reverse(sequenceGroups).equals(oldGroups)) {
+        List<Group> reverseSequenceGroups = new ArrayList<>(window.groups);
+        Collections.reverse(reverseSequenceGroups);
+        if (!sequenceGroups.equals(oldGroups) && !reverseSequenceGroups.equals(oldGroups)) {
             int offset = input.getRowType().getFieldCount();
             List<int[]> aggTypeIndexes = new ArrayList<>();
             for (Group group : oldGroups) {