Flink这个state会跑着跑着自己重置为0大小重新开始计算增量吗?
不会,Flink中的状态数据不会自动重置为0大小重新开始计算增量。Flink的状态是持久化的,即在作业执行期间会一直存储在内存或者磁盘上,直到作业结束或者显式地清除状态数据。因此,如果状态数据已经存储在内存或者磁盘上,Flink不会自动重置状态数据为0大小。
在Flink中,状态数据通常用于存储和维护作业执行期间的中间结果和状态信息。在增量计算等场景中,状态数据可以用于保存之前计算的结果,以便在后续计算中进行增量更新和处理。因此,在执行增量计算时,Flink会保留之前的状态数据,并在此基础上进行计算,以实现增量计算的效果。
需要注意的是,如果您的作业中的状态数据过大,可能会导致内存或者磁盘的压力过大,影响作业执行的性能和稳定性。在这种情况下,可以考虑使用状态后端(state backend)将状态数据存储到磁盘上,避免全部存储在内存中。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。