我有一个应用场景，想请教下大家有没有遇过，有什么好的方案？
hi，社区的小伙伴，大家好！我有一个应用场景，想请教下大家有没有遇过，有什么好的方案。 > 场景就是：按照user和day的维度统计订单表里的有效订单数，同时存在历史的订单状态随时可能被更新，比如可能当前把2个月前的订单状态置未true，所以没法根据历史结果预统计，翻译称sql就是select user,day,count() from table where state = true group by user,day；目前我已经用flink-sql-cdc-connector实现了，但是有一个问题就是state，因为按user day组合 那么如果全部状态都保存后期回越来越大，但是如果设置ttl，那么如果历史订单变化，最终更新出去的值也不对。 > 希望社区的小伙伴给我出出主意来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
我觉得我们遇到的问题有些类似，看下我们的方案对你是否有所帮助。首先，我们会把day这个条件控制在3天（select * where day >now-3），状态的TTL也是3天，即flink保留3天的状态，这样即使有3天前的数据到来也不会更新我们的结果表；这样可以解决更新错误的问题。然后，通过离线任务来定时修正3天前的结果数据。这样可以保证数据的最终一致性。*来自志愿者整理的flink
2021-12-07 21:38:08赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
