你好,
目前的 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上添加从而可以细粒度控制吗?