Flink如何处理跨State生命周期数据?

通过flink我们可以基于某个订单表实时统计售卖的订单金额。但是如果订单变动会跨Flink的生命周期要如何处理?

具体而言,订单ID 1 是一个金额为100的明细数据,在它刚创建的时候,我统计了该条明细的金额。但是如果在该明细创建过了一个月,这个明细的非金额字段发生了变化(比如某个状态字段),使得这条数据又进入了Flink,State中又没有该明细的历史数据,导致我把该数据又算了一边。由于State生命周期又不能无限制的扩大,请问有什么好方法可以处理这种问题么?

全部评论
点赞 回复 分享
发布于 2023-11-22 17:49 广东

相关推荐

03-13 21:15
江南大学 Java
多少分能进面啊?卡测评吗?做的我道心破碎了💔
小南瓜_66:A3 第四道题为什么用例过了 结果显示0%
投递携程等公司10个岗位 > 携程求职进展汇总
点赞 评论 收藏
分享
评论
点赞
收藏
分享

创作者周榜

更多
牛客网
牛客企业服务