panxiaohu created FLINK-19444:
---------------------------------
Summary: flink 1.11 sql group by tumble Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered
Key: FLINK-19444
URL:
https://issues.apache.org/jira/browse/FLINK-19444 Project: Flink
Issue Type: Bug
Components: Table SQL / API
Affects Versions: 1.11.2
Reporter: panxiaohu
Here's the code:
String createSql = "CREATE TABLE clicks (\n" +
" `user` STRING,\n" +
" create_time TIMESTAMP(3),\n" +
" PRIMARY KEY (`user`) NOT ENFORCED\n" +
") WITH (\n" +
" 'connector' = 'jdbc',\n" +
" 'url' = 'jdbc:mysql://localhost:3306/learning',\n" +
" 'username' = 'root',\n" +
" 'password' = 'john123',\n" +
" 'table-name' = 'clicks'\n" +
")";
Table table = tableEnv.sqlQuery("select user,TUMBLE_START(create_time, INTERVAL '1' DAY),count(user) from clicks group by TUMBLE(create_time, INTERVAL '1' DAY),user" );
then exception occurs as follows:
org.apache.flink.table.api.TableException: Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered.org.apache.flink.table.api.TableException: Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered.
at org.apache.flink.table.planner.plan.rules.logical.StreamLogicalWindowAggregateRule.getInAggregateGroupExpression(StreamLogicalWindowAggregateRule.scala:50) at org.apache.flink.table.planner.plan.rules.logical.LogicalWindowAggregateRuleBase.onMatch(LogicalWindowAggregateRuleBase.scala:79) at org.apache.calcite.plan.AbstractRelOptPlanner.fireRule(AbstractRelOptPlanner.java:328) at org.apache.calcite.plan.hep.HepPlanner.applyRule(HepPlanner.java:562) at org.apache.calcite.plan.hep.HepPlanner.applyRules(HepPlanner.java:427) at org.apache.calcite.plan.hep.HepPlanner.executeInstruction(HepPlanner.java:264) at org.apache.calcite.plan.hep.HepInstruction$RuleInstance.execute(HepInstruction.java:127)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
Locked
