Hi,
I want a top n result on each hop window result, but some error throws
out when I add the order by sentence or the limit sentence, so how do I
implement such case ?
Thanks a lot.
SELECT
trackId as id,track_title as description, count(*) as cnt
FROM
play
WHERE
appName='play.statistics.trace'
GROUP BY
HOP(started_at_ts, INTERVAL '1' SECOND, INTERVAL '5'
MINUTE),trackId,track_title
ORDER BY
cnt desc
LIMIT 10
FlinkLogicalSort(sort0=[$2], dir0=[DESC])
FlinkLogicalWindowAggregate(group=[{1, 2}], cnt=[COUNT()])
FlinkLogicalCalc(expr#0..4=[{inputs}],
expr#5=[_UTF-16LE'play.statistics.trace'], expr#6=[=($t0, $t5)],
started_at_ts=[$t4], trackId=[$t1], track_title=[$t2], $condition=[$t6])
FlinkLogicalNativeTableScan(table=[[play]])
This exception indicates that the query uses an unsupported SQL feature.
Please check the documentation for the set of currently supported SQL features.
at
org.apache.flink.table.api.TableEnvironment.runVolcanoPlanner(TableEnvironment.scala:275)
at
org.apache.flink.table.api.StreamTableEnvironment.optimize(StreamTableEnvironment.scala:845)
at
org.apache.flink.table.api.StreamTableEnvironment.translate(StreamTableEnvironment.scala:892)
at
org.apache.flink.table.api.StreamTableEnvironment.writeToSink(StreamTableEnvironment.scala:344)
at
org.apache.flink.table.api.TableEnvironment.insertInto(TableEnvironment.scala:786)
at
org.apache.flink.table.api.TableEnvironment.sqlUpdate(TableEnvironment.scala:723)
at
org.apache.flink.table.api.TableEnvironment.sqlUpdate(TableEnvironment.scala:683)
Best
Henry