sunjincheng created FLINK-6737:
----------------------------------
Summary: Fix over expression parse String error.
Key: FLINK-6737
URL: https://issues.apache.org/jira/browse/FLINK-6737
Project: Flink
Issue Type: Sub-task
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)
