FlinkSQL 窗口使用问题
Hi,
SELECT
TUMBLE_START(ts, INTERVAL '1' day) as window_start,
TUMBLE_END(ts, INTERVAL '1' day) as window_end,
c1,
sum(c2) as sc2
FROM sourcetable
GROUP BY TUMBLE(ts, INTERVAL '1' day), c1
ORDER BY window_start, sc2 desc limit 10
这个sql希望能够以一天为窗口（翻滚）进行计算窗口 按照c1分组，并对c2列求和(sc2)后对sc2进行窗口内排序。但是结果看起来，结果集中窗口内的数据列sc2并没有有序(降序/或者升序)排列。 能不能根据我的需求和sql的写法诊断一下问题出在哪里？或者说给一下建议，好让我定位到自己对flinksql使用的误区在哪？
谢谢！*来自志愿者整理的flink
写回答
-
目前确实不支持。将来可以结合 FLIP-145 window TVF 语法来支持 [1]。 [1]: https://cwiki.apache.org/confluence/display/FLINK/FLIP-145%3A+Support+SQL+windowing+table-valued+function*来自志愿者整理的flink
2021-12-06 18:26:23赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
