Fix window frame check

trinodb · Jun 21, 2021 · 53deff6 · 53deff6
1 parent f304a34
commit 53deff6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/trino-main/src/main/java/io/trino/sql/planner/LocalExecutionPlanner.java b/core/trino-main/src/main/java/io/trino/sql/planner/LocalExecutionPlanner.java
@@ -1229,7 +1229,7 @@ public PhysicalOperation visitPatternRecognition(PatternRecognitionNode node, Lo
                     .map(baseFrame -> {
                         checkArgument(
                                 baseFrame.getType() == ROWS &&
-                                        baseFrame.getEndType() == CURRENT_ROW,
+                                        baseFrame.getStartType() == CURRENT_ROW,
                                 "invalid base frame");
                         return new FrameInfo(
                                 baseFrame.getType(),