架构图

image.png
数据流描述
1.transfer负责将原始的监控数据推给kafka
2.flink从kafka消费监控数据
3.flink执行指标聚合任务
4.flink将聚合后的监控数据推给kafka
5.transfer从kafka中消费聚合后的数据，上报的监控存储后端

flink任务中断常见原因

  1. flink 进程异常退出
  2. 由于oom导致flink任务被杀死