课程内容修正:数据过期判断依据:上次修改的时间戳 + 我们设置的状态TTL <= 当前时间戳

课程内容修正:数据过期判断依据:上次修改的时间戳 + 我们设置的状态TTL <= 当前时间戳

课程中的原始内容为:数据过期判断依据:上次修改的时间戳 + 我们设置的状态TTL > 当前时间戳

正在回答 回答被采纳积分+1

登陆购买课程后可参与讨论,去登陆

1回答
提问者 徐老师 2023-11-08 11:26:51

通过查看State底层相关源码,发现这个计算公式应该是这样的:

lastAccessTimestam + ttl <= currentTimestamp


如果满足这个条件,则State过期。


所以应该是这样的:

数据过期判断依据:上次修改的时间戳 + 我们设置的状态TTL <= 当前时间戳


核心内容来源于类org.apache.flink.runtime.state.ttl.TtlUtils中的expired方法。


问题已解决,确定采纳
还有疑问,暂不采纳

恭喜解决一个难题,获得1积分~

来为老师/同学的回答评分吧

0 星
请稍等 ...
微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号

在线咨询

领取优惠

免费试听

领取大纲

扫描二维码,添加
你的专属老师