与StatsD计数器度量比较的Flink

Question

谈到有关StatsD的计数器，它的工作方式是您一直张贴一个计数器的值。每当应用程序收到对StatsD守护进程的请求时，都会使用StatsD。守护进程有一个刷新间隔集，当它在此期间将此计数器的聚合推送到外部后端时。此外，它还将计数器重置为0。

试图把这个映射到Flink计数器。

1. Flink计数器只有inc和dec方法，所以在报告时间到来之前，app可以调用inc或dec来更改计数器的值。在编写本报告时，
2. 向StatsD守护进程报告计数器的最新值，但Flink计数器值从未重置(无法找到任何代码)。

因此，应将flink计数器报告为StatsD的量值。还是Flink会重置计数器？

Answer 1

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

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