开发者社区 问答 正文

实时计算 Flink数据的状态保存时间是多久?

实时计算状态管理

展开
收起
李博 bluemind 2018-11-15 11:22:38 7458 分享 版权
1 条回答
写回答
取消 提交回答
  • 云栖社区Java、Redis、MongoDB运营小编,有意合作请联系钉钉:15810436147

    实时计算 Flink数据的状态保存在36小时之内,超过36小时没有数据流入的情况下,之前的状态以及数据会被清掉。


    场景分析
    假设,当前时间是4月1号,启动一个作业做有状态的计算(增量计算),如果后续10天内都没有数据流入实时计算,将会导致之前保存的增量计算的状态被清除了(实时计算最大保存状态的时间是36个小时),所有计算结果只是10天后结果而不是您想要的结果。建议您不要做全局的增量计算。

    2019-07-17 23:14:22
    赞同 展开评论