开发者社区> 问答> 正文

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

展开
收起
毛毛虫雨 2021-12-06 15:24:04 1479 0
1 条回答
写回答
取消 提交回答
  • 多个字段的排序,每个字段都要指定排序类型,默认是升序,你的第一个字段是升序,第二个才是。所以看到的顺序不是你想要的。*来自志愿者整理的flink

    2021-12-06 15:58:58
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载