回撤流的窗口统计

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

回撤流的窗口统计

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

Re: 回撤流的窗口统计

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

lincoln lee


casel.chen <[hidden email]> 于2021年6月5日周六 下午2:24写道:

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