回撤流的窗口统计

["casel.chen" <ca...@126.com>]

上游是binlog cdc消费获取的回撤流，现要使用flink sql统计分析该回撤流上每5分钟的sum值，不能使用常规tumble window是吗？只能使用group by ts配合state TTL进行？
另外，问一下flink sql的state TTL只能是全局设置吗？能够通过在sql hint上添加从而可以细粒度控制吗？

Re: 回撤流的窗口统计

[Lincoln Lee <li...@gmail.com>]

你好，
      目前的 tumble window 还不支持输入是更新流， 可以用 group by ts 配合 state ttl 来实现。
'table.exec.state.ttl' 是作业级别设置， 当前 sql 还不支持更细粒度的 state ttl 设置。如果有具体的想法，可以在
flink dev 邮件列表发起讨论或提交 jira issue，欢迎贡献社区！

lincoln lee


casel.chen <ca...@126.com> 于2021年6月5日周六 下午2:24写道：

> 上游是binlog cdc消费获取的回撤流，现要使用flink sql统计分析该回撤流上每5分钟的sum值，不能使用常规tumble
> window是吗？只能使用group by ts配合state TTL进行？
> 另外，问一下flink sql的state TTL只能是全局设置吗？能够通过在sql hint上添加从而可以细粒度控制吗？