hi, all ! flink版本:1.9需求:统计用户每天的订单数据(订单可以修改,导致同一个订单会有条数据,最终根据时间排序取最新的一条来做统计)。 应用:select userId,sum(money) as result,ymd from ( select userId,order_id,money,DATE_FORMAT(trans_time,'yyyyMMdd') as ymd,row_number() over(partition by order_id order by last_modify_time desc) as rk from MyTable where type='1' ) t where t.rk = 1 group by userId,ymd; 配置:tableConfig.setIdleStateRetentionTime(Time.milliseconds(3600000), Time.milliseconds(390000)); --相当于设置了1小时的过期时间 现象:checkpoint的数据大小一直在增加(应该是ttl状态过期未生效) 问题:翻看了jira,发现有人已经提出了这个问题【1】,想问一下这个问题还有什么补救的措施吗?
【1】https://issues.apache.org/jira/browse/FLINK-17096*来自志愿者整理的flink
目前看1.9应该没有补救方案了,可以试试master分支,把这个PR merge进去,编译一下,希望对你有所帮助*来自志愿者整理的flink
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。