Flink 与 StatsD 计数器指标比较

Question

谈到与 StatsD 相关的计数器，它的工作方式是你不断发布计数器的值，例如。numOfRequests|c:1每当应用程序收到对 StatsD 守护程序的请求时。守护程序在该时间段内将此计数器的聚合推送到外部后端时，设置了刷新间隔。此外，它还会将计数器重置为 0。

尝试将其映射到 Flink 计数器。

1. Flink 计数器只有 inc 和 dec 方法，所以在报告时间到来之前，应用程序可以调用 inc 或 dec 来更改计数器的值。
2. 在报告时，计数器的最新值被报告给 StatsD 守护进程，但 Flink 计数器值永远不会重置(找不到任何代码(。

因此，flink 计数器是否应作为仪表值报告给 StatsD。或者 Flink 会重置计数器？

Answer 1

Flink 计数器基本上是一种仪表值。计数器永远不会重置。因此，numRecordsIn/numRecordsOut或任何其他计数器指标在作业的生命周期内不断增加。如果要可视化一段时间内的计数，则需要在报表方法中自行计算增量并将其发送到外部后端，或使用外部后端解决方案功能绘制增量图。

我们使用 Datadog 并使用以下方法来绘制一段时间内的增量：diff(sum:numRecordsIn{$app_name,$env}.rollup(max))