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

Reply via email to