谈到关于statsd的计数器，它的工作方式是不断地发布计数器的值。 numOfRequests|c:1 每当应用程序收到对statsd守护程序的请求时。当守护进程将此计数器在该时间段内的聚合推送到外部后端时，它设置了刷新间隔。此外，它还将计数器重置为0。
试图把它Map到flink计数器。
flink计数器只有inc和dec方法，所以在报告时间到来之前，应用程序可以调用inc或dec来更改计数器的值。
在报告时，计数器的最新值会报告给statsd守护进程，但flink计数器值永远不会重置（找不到任何代码）。
因此，应该将flink计数器作为一个规范值报告给statsd。或者Flink会重置计数器？
1条答案
按热度按时间soat7uwm1#
flink计数器基本上是一种规范值。计数器从不复位。所以呢
numRecordsIn/numRecordsOut或者在工作的整个生命周期中，任何其他计数器指标都在不断增加。如果要可视化某个持续时间内的计数，则需要自己在报表方法中计算增量并将其发送到外部后端，或者使用外部后端解决方案功能来绘制增量。我们使用datadog并使用以下方法来绘制一段时间内的增量：
diff(sum:numRecordsIn{$app_name,$env}.rollup(max))