60-270-040-源碼-指標監測-Flink自定義metric監控流入量

1.美圖 2.概述 ​ flink任務本身提供了各種類型的指標監控，細化到了每一個Operator的流入/流出量、速率、Watermark值等，通常在實際應用中需要對接入數據做格式化例如轉json，符合要求的數據會向下流動，不符合要求或者格式化異常稱爲髒數據會被過濾掉，現在目標實現一個通用化方式能夠對正常數據與髒數據進行指標統計。 實現思路： flink metric類型分爲Counter、Gau

>>阅读原文<<