sunjincheng created FLINK-7024:
----------------------------------
Summary: Add supported for selecting window proctime/rowtime on
row-based Tumble/Slide window
Key: FLINK-7024
URL: https://issues.apache.org/jira/browse/FLINK-7024
Project: Flink
Issue Type: Bug
Components: Table API & SQL
Affects Versions: 1.4.0
Reporter: sunjincheng
Assignee: sunjincheng
We get validate exception,when selecting window.proctime/rowtime on row-based
group window.
{code}
table
.window(Tumble over 2.rows on 'proctime as 'w)
.groupBy('w, 'string)
.select('string, countFun('string) as 'cnt, 'w.rowtime as 'proctime)
.window(Over partitionBy 'string orderBy 'proctime preceding
UNBOUNDED_RANGE following CURRENT_RANGE as 'w2)
.select('string, 'cnt.sum over 'w2 as 'cnt)
{code}
Exception:
{code}
org.apache.flink.table.api.ValidationException: Window start and Window end
cannot be selected for a row-count Tumbling window.
at
org.apache.flink.table.plan.logical.LogicalNode.failValidation(LogicalNode.scala:143)
at
org.apache.flink.table.plan.logical.WindowAggregate.validate(operators.scala:660)
{code}
We should add window.proctime/rowtime check in `validate ` method.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
