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

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

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

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

相关推荐

评论
点赞
收藏
分享

创作者周榜

更多
牛客网
牛客企业服务