[jira] [Created] (FLINK-6737) Fix over expression parse String error.

[Shang Yuanchun (Jira)]

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)