[
https://issues.apache.org/jira/browse/FLINK-37321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17928380#comment-17928380
]
Sergey Nuyanzin commented on FLINK-37321:
-----------------------------------------
Merged as
[18c6cafe7f41765850f793d0fd11f8ef1370064a|https://github.com/apache/flink/commit/18c6cafe7f41765850f793d0fd11f8ef1370064a]
> Make window functions with wrong input fail during planning rather than
> runtime
> -------------------------------------------------------------------------------
>
> Key: FLINK-37321
> URL: https://issues.apache.org/jira/browse/FLINK-37321
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / Planner
> Reporter: Sergey Nuyanzin
> Assignee: Sergey Nuyanzin
> Priority: Major
> Labels: pull-request-available
>
> examples
> {code:sql}
> SELECT *
> FROM TABLE(
> CUMULATE(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '0' MINUTE, INTERVAL
> '0' HOUR))
> {code}
> {code:sql}
> SELECT *
> FROM TABLE(
> HOP(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '0' MINUTE, INTERVAL '0'
> MINUTE))
> {code}
> {code:sql}
> SELECT *
> FROM TABLE(TUMBLE(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '0' MINUTE))
> {code}
> {code:sql}
> SELECT *
> FROM TABLE(SESSION(TABLE MyTable, DESCRIPTOR(rowtime), INTERVAL '0' MINUTE))
> {code}
> since currently we assume that window descriptors are constant, then we could
> add this check at planning
> https://github.com/apache/flink/blob/cd0cfe42c15042a3c27a0c341416aa32c0d594b6/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowUtil.scala#L394
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
