你好,

CDC Source 目前不支持窗口函数。

不过可以考虑通过非窗口聚合的方式实现类似的效果。具体方法为:

   1.

   使用DATE_FORMAT函数,将时间字段转换成分钟粒度的字符串,作为窗口值。
   2.

   根据窗口值进行GROUP BY聚合。

Best,
Hang

Xuyang <xyzhong...@163.com> 于2024年1月17日周三 19:34写道:

> Hi,
> Flink SQL中可以用Group Window[1]的方式来读完cdc数据后加窗口。
> 可以具体描述一下“一直不生效”的现象和SQL么?
>
>
>
> [1]
> https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/table/sql/queries/window-agg/#selecting-group-window-start-and-end-timestamps-1
>
>
>
>
> --
>
>     Best!
>     Xuyang
>
>
>
>
>
> 在 2024-01-17 19:24:03,"2813732510" <2813732...@qq.com.INVALID> 写道:
> >flink&nbsp;&nbsp;cdc&nbsp;读取binlog数据后面可以开窗吗,测试滑动窗口,聚合,一直不生效,是有什么特别的用法嘛
>

回复