[
https://issues.apache.org/jira/browse/FLINK-7024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16066575#comment-16066575
]
ASF GitHub Bot commented on FLINK-7024:
---------------------------------------
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4210
CC @wuchong @twalthr :-)
> 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)
