[
https://issues.apache.org/jira/browse/FLINK-37321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-37321:
------------------------------------
Description:
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
was:
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
> 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
>
> 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)
