[ https://issues.apache.org/jira/browse/FLINK-6737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028344#comment-16028344 ]
sunjincheng commented on FLINK-6737: ------------------------------------ [~twalthr][~fhueske] Agree with you. I have updated the PR. And this PR only `Fix string reference variable error.` Please look at the PR. Thanks, SunJincheng > Fix over expression parse String error. > --------------------------------------- > > Key: FLINK-6737 > URL: https://issues.apache.org/jira/browse/FLINK-6737 > Project: Flink > Issue Type: Sub-task > Components: Table API & SQL > Affects Versions: 1.3.0 > Reporter: sunjincheng > Assignee: sunjincheng > > When we run the TableAPI as follows: > {code} > val windowedTable = table > .window(Over partitionBy 'c orderBy 'proctime preceding UNBOUNDED_ROW > as 'w) > .select('c, "countFun(b)" over 'w as 'mycount, weightAvgFun('a, 'b) > over 'w as 'wAvg) > {code} > We get the error: > {code} > org.apache.flink.table.api.TableException: The over method can only using > with aggregation expression. > at > org.apache.flink.table.api.scala.ImplicitExpressionOperations$class.over(expressionDsl.scala:469) > at > org.apache.flink.table.api.scala.ImplicitExpressionConversions$LiteralStringExpression.over(expressionDsl.scala:756) > {code} > The reason is, the `over` method of `expressionDsl` not parse the String case. > I think we should fix this before 1.3 release. -- This message was sent by Atlassian JIRA (v6.3.15#6346)