flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "sunjincheng (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6737) Fix over expression parse String error.
Date Sat, 27 May 2017 04:45:04 GMT
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:
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)
We get the error:
org.apache.flink.table.api.TableException: The over method can only using with aggregation

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

View raw message