开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink这个state会跑着跑着自己重置为0大小重新开始计算增量吗?

Flink这个state会跑着跑着自己重置为0大小重新开始计算增量吗?

展开
收起
三分钟热度的鱼 2023-08-08 12:11:02 62 0
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    不会,Flink中的状态数据不会自动重置为0大小重新开始计算增量。Flink的状态是持久化的,即在作业执行期间会一直存储在内存或者磁盘上,直到作业结束或者显式地清除状态数据。因此,如果状态数据已经存储在内存或者磁盘上,Flink不会自动重置状态数据为0大小。

    在Flink中,状态数据通常用于存储和维护作业执行期间的中间结果和状态信息。在增量计算等场景中,状态数据可以用于保存之前计算的结果,以便在后续计算中进行增量更新和处理。因此,在执行增量计算时,Flink会保留之前的状态数据,并在此基础上进行计算,以实现增量计算的效果。

    需要注意的是,如果您的作业中的状态数据过大,可能会导致内存或者磁盘的压力过大,影响作业执行的性能和稳定性。在这种情况下,可以考虑使用状态后端(state backend)将状态数据存储到磁盘上,避免全部存储在内存中。

    2023-08-08 18:26:26
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载