实时计算状态管理
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算 Flink数据的状态保存在36小时之内,超过36小时没有数据流入的情况下,之前的状态以及数据会被清掉。
场景分析
假设,当前时间是4月1号,启动一个作业做有状态的计算(增量计算),如果后续10天内都没有数据流入实时计算,将会导致之前保存的增量计算的状态被清除了(实时计算最大保存状态的时间是36个小时),所有计算结果只是10天后结果而不是您想要的结果。建议您不要做全局的增量计算。