flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-7024) Add supported for selecting window proctime/rowtime on row-based Tumble/Slide window
Date Wed, 28 Jun 2017 14:25:00 GMT

    [ 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)

Mime
View raw message