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
展开
收起
1
条回答
写回答
写回答
-
多个字段的排序，每个字段都要指定排序类型，默认是升序，你的第一个字段是升序，第二个才是。所以看到的顺序不是你想要的。*来自志愿者整理的flink
2021-12-06 15:58:58赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
