60-270-040-源码-指标监测-Flink自定义metric监控流入量

1.美图 2.概述 ​ flink任务本身提供了各种类型的指标监控，细化到了每一个Operator的流入/流出量、速率、Watermark值等，通常在实际应用中需要对接入数据做格式化例如转json，符合要求的数据会向下流动，不符合要求或者格式化异常称为脏数据会被过滤掉，现在目标实现一个通用化方式能够对正常数据与脏数据进行指标统计。 实现思路： flink metric类型分为Counter、Gau

>>阅读原文<<