网站首页
编程语言
数据库
系统相关
其他分享
编程问答
DirtyDataCollector
2024-06-30
【Flink metric(3)】chunjun是如何实现脏数据管理的
文章目录一.基础逻辑二.DirtyManager1.初始化2.收集脏数据并check3.关闭资源三.DirtyDataCollector1.初始化2.收集脏数据并check3.run:消费脏数据4.释放资源四.LogDirtyDataCollector一.基础逻辑脏数据管理模块的基本逻辑是:当数据消费失败时,将脏数据