回撤流的窗口统计的问题？
上游是binlog cdc消费获取的回撤流，现要使用flink sql统计分析该回撤流上每5分钟的sum值，不能使用常规tumble window是吗？只能使用group by ts配合state TTL进行？ 另外，问一下flink sql的state TTL只能是全局设置吗？能够通过在sql hint上添加从而可以细粒度控制吗？*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
你好，
目前的 tumble window 还不支持输入是更新流， 可以用 group by ts 配合 state ttl 来实现。
'table.exec.state.ttl' 是作业级别设置， 当前 sql 还不支持更细粒度的 state ttl 设置。如果有具体的想法，可以在
flink dev 邮件列表发起讨论或提交 jira issue，欢迎贡献社区！*来自志愿者整理的FLINK邮件归档
2021-12-02 14:33:39赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
