[fix] (mtmv) Fix topN rewrite by materialized view fail and cause rewrite result wrong (#58406)

seawinde · web-flow · commit dd0d323af44b · 2025-12-03T15:22:11.000+08:00
### What problem does this PR solve?

This PR addresses two issues: 
1 it stabilizes the regression tests for `topN_rewrite` and
`limit_rewrite`, and
2 it fixes a bug affecting negative test cases. For example, the
following case should not be rewritten successfully but was incorrectly
rewritten

         CREATE MATERIALIZED VIEW mv
        BUILD IMMEDIATE REFRESH COMPLETE ON MANUAL
        DISTRIBUTED BY RANDOM BUCKETS 2
        PROPERTIES ('replication_num' = '1') 
        AS
            select
            o_orderdate,
            ps_partkey,
            l_orderkey
            from
            orders left
            join lineitem on l_orderkey = o_orderkey
            left join partsupp on ps_partkey = l_partkey and l_suppkey = ps_suppkey
            where o_orderdate &gt; '2025-01-02'
            order by o_orderdate, l_orderkey, ps_partkey
            limit 8 offset 1;

the query as following should not rewrite successfully

            select
            o_orderdate,
            ps_partkey,
            l_orderkey
            from
            orders left
            join lineitem on l_orderkey = o_orderkey
            left join partsupp on ps_partkey = l_partkey and l_suppkey = ps_suppkey
            order by o_orderdate, l_orderkey
            limit 4 offset 2;
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/AbstractMaterializedViewRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/AbstractMaterializedViewRule.java
@@ -1066,9 +1066,9 @@ protected Plan tryRewriteTopN(LogicalTopN<Plan> queryTopNode, LogicalTopN<Plan>
         // check the order keys of TopN between query and view is consistent
         List<OrderKey> queryOrderKeys = queryTopNode.getOrderKeys();
         List<OrderKey> viewOrderKeys = viewTopNode.getOrderKeys();
-        if (queryOrderKeys.size() != viewOrderKeys.size()) {
+        if (queryOrderKeys.size() > viewOrderKeys.size()) {
             materializationContext.recordFailReason(queryStructInfo,
-                    "query topN order keys size is not consistent with view topN order keys size",
+                    "query topN order keys size is bigger than view topN order keys size",
                     () -> String.format("query topN order keys = %s,\n view topN order keys = %s,\n",
                             queryOrderKeys, viewOrderKeys));
             return null;
@@ -1096,7 +1096,7 @@ protected Plan tryRewriteTopN(LogicalTopN<Plan> queryTopNode, LogicalTopN<Plan>
             viewShuttledOrderKeys.add(new OrderKey(viewOrderByExpressionsQueryBasedSet.get(j), viewOrderKey.isAsc(),
                     viewOrderKey.isNullFirst()));
         }
-        if (!queryShuttledOrderKeys.equals(viewShuttledOrderKeys)) {
+        if (!MaterializedViewUtils.isPrefixSameFromStart(queryShuttledOrderKeys, viewShuttledOrderKeys)) {
             materializationContext.recordFailReason(queryStructInfo,
                     "view topN order key doesn't match query order key",
                     () -> String.format("queryShuttledOrderKeys = %s,\n viewShuttledOrderKeys = %s,\n",
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/AbstractMaterializedViewScanRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/AbstractMaterializedViewScanRule.java
@@ -90,6 +90,8 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca
     protected boolean checkMaterializationPattern(StructInfo structInfo, CascadesContext cascadesContext) {
         PlanCheckContext checkContext = PlanCheckContext.of(SUPPORTED_JOIN_TYPE_SET);
         return structInfo.getTopPlan().accept(StructInfo.PLAN_PATTERN_CHECKER, checkContext)
-                && !checkContext.isContainsTopAggregate();
+                && !checkContext.isContainsTopAggregate()
+                && !checkContext.isContainsTopLimit() && !checkContext.isContainsTopTopN()
+                && !checkContext.isContainsTopWindow();
     }
 }
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewAggregateOnNoneAggregateRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewAggregateOnNoneAggregateRule.java
@@ -82,13 +82,17 @@ protected boolean checkMaterializationPattern(StructInfo structInfo, CascadesCon
         // any check result of join or scan is true, then return true
         PlanCheckContext joinCheckContext = PlanCheckContext.of(SUPPORTED_JOIN_TYPE_SET);
         boolean joinCheckResult = structInfo.getTopPlan().accept(StructInfo.PLAN_PATTERN_CHECKER, joinCheckContext)
-                && !joinCheckContext.isContainsTopAggregate();
+                && !joinCheckContext.isContainsTopAggregate()
+                && !joinCheckContext.isContainsTopLimit() && !joinCheckContext.isContainsTopTopN()
+                && !joinCheckContext.isContainsTopWindow();
         if (joinCheckResult) {
             return true;
         }
         PlanCheckContext scanCheckContext = PlanCheckContext.of(ImmutableSet.of());
         return structInfo.getTopPlan().accept(StructInfo.SCAN_PLAN_PATTERN_CHECKER, scanCheckContext)
-                && !scanCheckContext.isContainsTopAggregate();
+                && !scanCheckContext.isContainsTopAggregate()
+                && !joinCheckContext.isContainsTopLimit() && !joinCheckContext.isContainsTopTopN()
+                && !joinCheckContext.isContainsTopWindow();
     }
 
     @Override
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewLimitAggregateRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewLimitAggregateRule.java
@@ -70,6 +70,7 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca
         return structInfo.getTopPlan().accept(StructInfo.PLAN_PATTERN_CHECKER, checkContext)
                 && checkContext.isContainsTopAggregate() && checkContext.getTopAggregateNum() == 1
                 && !checkContext.isContainsTopTopN()
+                && !checkContext.isContainsTopWindow()
                 && checkContext.isContainsTopLimit() && checkContext.getTopLimitNum() == 1;
     }
 
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewLimitJoinRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewLimitJoinRule.java
@@ -70,6 +70,7 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca
         return structInfo.getTopPlan().accept(StructInfo.PLAN_PATTERN_CHECKER, checkContext)
                 && !checkContext.isContainsTopAggregate()
                 && !checkContext.isContainsTopTopN()
+                && !checkContext.isContainsTopWindow()
                 && checkContext.isContainsTopLimit() && checkContext.getTopLimitNum() == 1;
     }
 
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewLimitScanRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewLimitScanRule.java
@@ -71,9 +71,15 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca
         return structInfo.getTopPlan().accept(StructInfo.SCAN_PLAN_PATTERN_CHECKER, checkContext)
                 && !checkContext.isContainsTopAggregate()
                 && !checkContext.isContainsTopTopN()
+                && !checkContext.isContainsTopWindow()
                 && checkContext.isContainsTopLimit() && checkContext.getTopLimitNum() == 1;
     }
 
+    @Override
+    protected boolean checkMaterializationPattern(StructInfo structInfo, CascadesContext cascadesContext) {
+        return checkQueryPattern(structInfo, cascadesContext);
+    }
+
     @Override
     public List<Rule> buildRules() {
         return ImmutableList.of(
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewTopNAggregateRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewTopNAggregateRule.java
@@ -67,6 +67,7 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca
         return structInfo.getTopPlan().accept(StructInfo.PLAN_PATTERN_CHECKER, checkContext)
                 && checkContext.isContainsTopAggregate() && checkContext.getTopAggregateNum() == 1
                 && !checkContext.isContainsTopLimit()
+                && !checkContext.isContainsTopWindow()
                 && checkContext.isContainsTopTopN() && checkContext.getTopTopNNum() == 1;
     }
 
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewTopNJoinRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewTopNJoinRule.java
@@ -68,6 +68,7 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca
         return accept
                 && !checkContext.isContainsTopAggregate()
                 && !checkContext.isContainsTopLimit()
+                && !checkContext.isContainsTopWindow()
                 && checkContext.isContainsTopTopN() && checkContext.getTopTopNNum() == 1;
     }
 
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewTopNScanRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewTopNScanRule.java
@@ -69,9 +69,15 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca
         return accept
                 && !checkContext.isContainsTopAggregate()
                 && !checkContext.isContainsTopLimit()
+                && !checkContext.isContainsTopWindow()
                 && checkContext.isContainsTopTopN() && checkContext.getTopTopNNum() == 1;
     }
 
+    @Override
+    protected boolean checkMaterializationPattern(StructInfo structInfo, CascadesContext cascadesContext) {
+        return checkQueryPattern(structInfo, cascadesContext);
+    }
+
     @Override
     public List<Rule> buildRules() {
         return ImmutableList.of(
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewUtils.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewUtils.java
@@ -24,6 +24,7 @@
 import org.apache.doris.nereids.StatementContext;
 import org.apache.doris.nereids.memo.Group;
 import org.apache.doris.nereids.memo.StructInfoMap;
+import org.apache.doris.nereids.properties.OrderKey;
 import org.apache.doris.nereids.rules.RuleType;
 import org.apache.doris.nereids.rules.analysis.BindRelation;
 import org.apache.doris.nereids.rules.exploration.mv.PartitionIncrementMaintainer.PartitionIncrementCheckContext;
@@ -651,4 +652,23 @@ public Boolean visit(Plan plan, Void context) {
             return false;
         }
     }
+
+    /**
+     * Check the prefix of two order key list is same from start
+     */
+    public static boolean isPrefixSameFromStart(List<OrderKey> queryShuttledOrderKeys,
+                                                 List<OrderKey> viewShuttledOrderKeys) {
+        if (queryShuttledOrderKeys == null || viewShuttledOrderKeys == null) {
+            return false;
+        }
+        if (queryShuttledOrderKeys.size() > viewShuttledOrderKeys.size()) {
+            return false;
+        }
+        for (int i = 0; i < queryShuttledOrderKeys.size(); i++) {
+            if (!java.util.Objects.equals(queryShuttledOrderKeys.get(i), viewShuttledOrderKeys.get(i))) {
+                return false;
+            }
+        }
+        return true;
+    }
 }
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewWindowAggregateRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewWindowAggregateRule.java
@@ -54,7 +54,8 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca
         return structInfo.getTopPlan().accept(StructInfo.PLAN_PATTERN_CHECKER, checkContext)
                 && checkContext.isContainsTopAggregate() && checkContext.isContainsTopWindow()
                 && checkContext.getTopAggregateNum() <= 1 && checkContext.getTopWindowNum() <= 1
-                && !checkContext.isWindowUnderAggregate();
+                && !checkContext.isWindowUnderAggregate()
+                && !checkContext.isContainsTopTopN() && !checkContext.isContainsTopLimit();
     }
 
     @Override
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewWindowJoinRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewWindowJoinRule.java
@@ -54,7 +54,8 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca
         PlanCheckContext checkContext = PlanCheckContext.of(SUPPORTED_JOIN_TYPE_SET);
         return structInfo.getTopPlan().accept(StructInfo.PLAN_PATTERN_CHECKER, checkContext)
                 && !checkContext.isContainsTopAggregate() && checkContext.isContainsTopWindow()
-                && checkContext.getTopWindowNum() <= 1;
+                && checkContext.getTopWindowNum() <= 1
+                && !checkContext.isContainsTopTopN() && !checkContext.isContainsTopLimit();
     }
 
     @Override
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewWindowScanRule.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewWindowScanRule.java
@@ -55,7 +55,8 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca
         PlanCheckContext checkContext = PlanCheckContext.of(ImmutableSet.of());
         return structInfo.getTopPlan().accept(StructInfo.SCAN_PLAN_PATTERN_CHECKER, checkContext)
                 && !checkContext.isContainsTopAggregate() && checkContext.isContainsTopWindow()
-                && checkContext.getTopWindowNum() <= 1;
+                && checkContext.getTopWindowNum() <= 1
+                && !checkContext.isContainsTopTopN() && !checkContext.isContainsTopLimit();
     }
 
     @Override
diff --git a/fe/fe-core/src/test/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewUtilsTest.java b/fe/fe-core/src/test/java/org/apache/doris/nereids/rules/exploration/mv/MaterializedViewUtilsTest.java
@@ -20,14 +20,19 @@
 import org.apache.doris.catalog.Env;
 import org.apache.doris.catalog.TableIf;
 import org.apache.doris.mtmv.BaseTableInfo;
+import org.apache.doris.nereids.properties.OrderKey;
 import org.apache.doris.nereids.rules.exploration.mv.RelatedTableInfo.RelatedTableColumnInfo;
+import org.apache.doris.nereids.trees.expressions.literal.VarcharLiteral;
 import org.apache.doris.nereids.trees.plans.Plan;
 import org.apache.doris.nereids.util.PlanChecker;
 import org.apache.doris.utframe.TestWithFeService;
 
+import com.google.common.collect.ImmutableList;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 
+import java.util.List;
+
 /**
  * Test for materialized view util
  */
@@ -952,6 +957,76 @@ public void getRelatedTableInfoWhenMultiPartitionExprs() {
                         });
     }
 
+    // java
+    @Test
+    public void isPrefixSameFromStartNullAndEmptyTests() {
+        // both null
+        Assertions.assertFalse(MaterializedViewUtils.isPrefixSameFromStart(null, null));
+        // query null
+        List<OrderKey> view = ImmutableList.of(
+                new OrderKey(new VarcharLiteral("a"), true, false)
+        );
+        Assertions.assertFalse(MaterializedViewUtils.isPrefixSameFromStart(null, view));
+        // view null
+        List<OrderKey> query = ImmutableList.of(
+                new OrderKey(new VarcharLiteral("a"), true, false)
+        );
+        Assertions.assertFalse(MaterializedViewUtils.isPrefixSameFromStart(query, null));
+        List<OrderKey> emptyQuery = ImmutableList.of();
+        List<OrderKey> emptyView = ImmutableList.of();
+        Assertions.assertTrue(MaterializedViewUtils.isPrefixSameFromStart(emptyQuery, emptyView));
+    }
+
+    @Test
+    public void isPrefixSameFromStart_queryLongerThanView() {
+        List<OrderKey> query = ImmutableList.of(
+                new OrderKey(new VarcharLiteral("a"), true, false),
+                new OrderKey(new VarcharLiteral("b"), true, false)
+        );
+        List<OrderKey> view = ImmutableList.of(
+                new OrderKey(new VarcharLiteral("a"), true, false)
+        );
+        Assertions.assertFalse(MaterializedViewUtils.isPrefixSameFromStart(query, view));
+    }
+
+    @Test
+    public void isPrefixSameFromStart_emptyQueryIsPrefix() {
+        List<OrderKey> emptyQuery = ImmutableList.of();
+        List<OrderKey> view = ImmutableList.of(
+                new OrderKey(new VarcharLiteral("x"), true, false),
+                new OrderKey(new VarcharLiteral("y"), true, false)
+        );
+        Assertions.assertTrue(MaterializedViewUtils.isPrefixSameFromStart(emptyQuery, view));
+    }
+
+    @Test
+    public void isPrefixSameFromStart_prefixEqualReturnsTrue() {
+        List<OrderKey> query = ImmutableList.of(
+                new OrderKey(new VarcharLiteral("a"), true, false),
+                new OrderKey(new VarcharLiteral("b"), true, false)
+        );
+        List<OrderKey> view = ImmutableList.of(
+                new OrderKey(new VarcharLiteral("a"), true, false),
+                new OrderKey(new VarcharLiteral("b"), true, false),
+                new OrderKey(new VarcharLiteral("c"), true, false)
+        );
+        Assertions.assertTrue(MaterializedViewUtils.isPrefixSameFromStart(query, view));
+    }
+
+    @Test
+    public void isPrefixSameFromStart_prefixNotEqualReturnsFalse() {
+        List<OrderKey> query = ImmutableList.of(
+                new OrderKey(new VarcharLiteral("a"), true, false),
+                new OrderKey(new VarcharLiteral("x"), true, false)
+        );
+        List<OrderKey> view = ImmutableList.of(
+                new OrderKey(new VarcharLiteral("a"), true, false),
+                new OrderKey(new VarcharLiteral("b"), true, false),
+                new OrderKey(new VarcharLiteral("c"), true, false)
+        );
+        Assertions.assertFalse(MaterializedViewUtils.isPrefixSameFromStart(query, view));
+    }
+
     private void checkRelatedTableInfo(RelatedTableInfo relatedTableInfo,
             String expectTableName,
             String expectColumnName,
diff --git a/regression-test/data/nereids_rules_p0/mv/topN/topN_rewrite.out b/regression-test/data/nereids_rules_p0/mv/topN/topN_rewrite.out
@@ -9,6 +9,28 @@
 2023-12-12	1	1	5	1
 2023-12-13	1	1	6	1
 
+-- !query1_3_before --
+2023-12-10	2	3
+2023-12-11	3	4
+2023-12-12	2	5
+2023-12-13	2	6
+
+-- !query1_3_after --
+2023-12-10	2	3
+2023-12-11	3	4
+2023-12-12	2	5
+2023-12-13	2	6
+
+-- !query1_4_before --
+2023-12-11	3	4
+2023-12-12	2	5
+2023-12-13	2	6
+
+-- !query1_4_after --
+2023-12-11	3	4
+2023-12-12	2	5
+2023-12-13	2	6
+
 -- !query1_1_before --
 2023-12-12	1	1	5	1
 2023-12-13	1	1	6	1
diff --git a/regression-test/suites/nereids_rules_p0/mv/limit/limit_rewrite.groovy b/regression-test/suites/nereids_rules_p0/mv/limit/limit_rewrite.groovy
@@ -580,7 +580,8 @@ suite("limit_rewrite") {
             where o_orderdate > '2023-12-08'
             limit 2 offset 5;
             """
-    async_mv_rewrite_success(db, mv5_1, query5_1, "mv5_1")
+    // mv data can not cover query limit offset, should fail
+    async_mv_rewrite_fail(db, mv5_1, query5_1, "mv5_1")
     sql """ DROP MATERIALIZED VIEW IF EXISTS mv5_1"""
 
 
@@ -606,7 +607,8 @@ suite("limit_rewrite") {
             where o_orderdate > '2023-12-09'
             limit 4 offset 2;
             """
-    async_mv_rewrite_success(db, mv5_2, query5_2, "mv5_2")
+    // mv data can not cover query limit offset, should fail
+    async_mv_rewrite_fail(db, mv5_2, query5_2, "mv5_2")
     sql """ DROP MATERIALIZED VIEW IF EXISTS mv5_2"""
 
 
@@ -657,7 +659,8 @@ suite("limit_rewrite") {
             orders
             limit 2 offset 5;
             """
-    async_mv_rewrite_success(db, mv6_1, query6_1, "mv6_1")
+    // mv data can not cover query limit offset, should fail
+    async_mv_rewrite_fail(db, mv6_1, query6_1, "mv6_1")
     sql """ DROP MATERIALIZED VIEW IF EXISTS mv6_1"""
 
 }
diff --git a/regression-test/suites/nereids_rules_p0/mv/topN/topN_rewrite.groovy b/regression-test/suites/nereids_rules_p0/mv/topN/topN_rewrite.groovy

Original file line number	Diff line number	Diff line change
`@@ -90,6 +90,8 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca`
`90`	`90`	`protected boolean checkMaterializationPattern(StructInfo structInfo, CascadesContext cascadesContext) {`
`91`	`91`	`PlanCheckContext checkContext = PlanCheckContext.of(SUPPORTED_JOIN_TYPE_SET);`
`92`	`92`	`return structInfo.getTopPlan().accept(StructInfo.PLAN_PATTERN_CHECKER, checkContext)`
`93`		`- && !checkContext.isContainsTopAggregate();`
	`93`	`+ && !checkContext.isContainsTopAggregate()`
	`94`	`+ && !checkContext.isContainsTopLimit() && !checkContext.isContainsTopTopN()`
	`95`	`+ && !checkContext.isContainsTopWindow();`
`94`	`96`	`}`
`95`	`97`	`}`
Original file line number	Diff line number	Diff line change
`@@ -70,6 +70,7 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca`
`70`	`70`	`return structInfo.getTopPlan().accept(StructInfo.PLAN_PATTERN_CHECKER, checkContext)`
`71`	`71`	`&& checkContext.isContainsTopAggregate() && checkContext.getTopAggregateNum() == 1`
`72`	`72`	`&& !checkContext.isContainsTopTopN()`
	`73`	`+ && !checkContext.isContainsTopWindow()`
`73`	`74`	`&& checkContext.isContainsTopLimit() && checkContext.getTopLimitNum() == 1;`
`74`	`75`	`}`
`75`	`76`
Original file line number	Diff line number	Diff line change
`@@ -67,6 +67,7 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca`
`67`	`67`	`return structInfo.getTopPlan().accept(StructInfo.PLAN_PATTERN_CHECKER, checkContext)`
`68`	`68`	`&& checkContext.isContainsTopAggregate() && checkContext.getTopAggregateNum() == 1`
`69`	`69`	`&& !checkContext.isContainsTopLimit()`
	`70`	`+ && !checkContext.isContainsTopWindow()`
`70`	`71`	`&& checkContext.isContainsTopTopN() && checkContext.getTopTopNNum() == 1;`
`71`	`72`	`}`
`72`	`73`
Original file line number	Diff line number	Diff line change
`@@ -68,6 +68,7 @@ protected boolean checkQueryPattern(StructInfo structInfo, CascadesContext casca`
`68`	`68`	`return accept`
`69`	`69`	`&& !checkContext.isContainsTopAggregate()`
`70`	`70`	`&& !checkContext.isContainsTopLimit()`
	`71`	`+ && !checkContext.isContainsTopWindow()`
`71`	`72`	`&& checkContext.isContainsTopTopN() && checkContext.getTopTopNNum() == 1;`
`72`	`73`	`}`
`73`	`74`